package main import ( "context" "fmt" "time" "github.com/linkerlin/GoExecutors/config" "github.com/linkerlin/GoExecutors/executors" ) func main() { // 创建配置 cfg := config.DefaultConfig() cfg.CorePoolSize = 4 cfg.MaxPoolSize = 8 cfg.QueueSize = 100 // 创建执行器 executor := executors.NewThreadPoolExecutor(cfg) defer executor.Shutdown() // 提交任务 task := executors.Callable(func(ctx context.Context) (interface{}, error) { fmt.Println("Hello, GoExecutors!") return "任务完成", nil }) future, err := executor.Submit(task) if err != nil { panic(err) } // 获取结果 result, err := future.Get() if err != nil { panic(err) } fmt.Printf("结果: %v\n", result) }

package main import ( "fmt" "time" "github.com/linkerlin/GoExecutors/executors" ) func main() { // 使用兼容的 API es := executors.NewExecutors() defer es.Stop() // 提交任务 callable := func() (interface{}, error) { return "Hello, World!", nil } future := es.Submit(callable) // 获取结果 ret, timeoutErr, err, exception := future.GetResult(1 * time.Second) if err != nil { fmt.Printf("错误: %v\n", err) } else if timeoutErr != nil { fmt.Printf("超时: %v\n", timeoutErr) } else if exception != nil { fmt.Printf("异常: %v\n", exception) } else { fmt.Printf("结果: %v\n", ret) } }

cfg := &config.Config{ CorePoolSize: 4, // 核心线程数 MaxPoolSize: 8, // 最大线程数 QueueSize: 100, // 队列大小 KeepAliveTime: 60 * time.Second, // 线程空闲时间 AllowCoreThreadTimeOut: false, // 是否允许核心线程超时 RejectPolicy: "abort", // 拒绝策略 ThreadNamePrefix: "goexecutor", // 线程名称前缀 EnableMetrics: true, // 启用性能监控 MetricsInterval: 10 * time.Second, // 指标收集间隔 EnableLogging: true, // 启用日志 LogLevel: "info", // 日志级别 }

task := executors.Callable(func(ctx context.Context) (interface{}, error) { // 执行任务逻辑 return "结果", nil })

type MyTask struct { Data string } func (t *MyTask) Execute(ctx context.Context) (interface{}, error) { // 执行任务逻辑 return t.Data + " 处理完成", nil } // 使用 task := &MyTask{Data: "测试数据"} future, err := executor.Submit(task)

// 提交任务 future, err := executor.Submit(task) // 阻塞获取结果 result, err := future.Get() // 带超时获取结果 result, err := future.GetWithTimeout(5 * time.Second) // 检查是否完成 if future.IsDone() { fmt.Println("任务已完成") } // 取消任务 future.Cancel()

// 启用性能监控 cfg.EnableMetrics = true // 获取性能指标 metrics := executor.GetMetrics() fmt.Printf("提交任务数: %d\n", metrics.TasksSubmitted) fmt.Printf("完成任务数: %d\n", metrics.TasksCompleted) fmt.Printf("失败任务数: %d\n", metrics.TasksFailed) fmt.Printf("活跃线程数: %d\n", metrics.ActiveThreads) fmt.Printf("平均执行时间: %v\n", metrics.AvgExecutionTime()) fmt.Printf("任务吞吐量: %.2f 任务/秒\n", metrics.TaskThroughput()) fmt.Printf("成功率: %.2f%%\n", metrics.SuccessRate()*100)

// 1. 正常错误 task := executors.Callable(func(ctx context.Context) (interface{}, error) { return nil, errors.New("业务错误") }) // 2. Panic 恢复 task := executors.Callable(func(ctx context.Context) (interface{}, error) { panic("发生恐慌") // 会被自动恢复 }) // 3. 上下文取消 task := executors.Callable(func(ctx context.Context) (interface{}, error) { select { case <-ctx.Done(): return nil, ctx.Err() default: // 执行任务 return "完成", nil } })

// 启动优雅关闭 executor.Shutdown() // 等待任务完成（带超时） if executor.AwaitTermination(30 * time.Second) { fmt.Println("执行器已优雅关闭") } else { fmt.Println("关闭超时，强制关闭") executor.ShutdownNow() }

// 批量提交任务 tasks := []executors.Task{ executors.Callable(func(ctx context.Context) (interface{}, error) { return "任务1", nil }), executors.Callable(func(ctx context.Context) (interface{}, error) { return "任务2", nil }), // ... 更多任务 } futures := make([]*executors.Future, len(tasks)) for i, task := range tasks { future, err := executor.Submit(task) if err != nil { fmt.Printf("提交任务 %d 失败: %v\n", i, err) continue } futures[i] = future } // 等待所有任务完成 for i, future := range futures { if future == nil { continue } result, err := future.Get() if err != nil { fmt.Printf("任务 %d 失败: %v\n", i, err) } else { fmt.Printf("任务 %d 结果: %v\n", i, result) } }

import "github.com/linkerlin/GoExecutors/logger" // 创建自定义日志器 customLogger := logger.NewSimpleLogger("debug") // 设置为全局日志器 logger.SetDefaultLogger(customLogger) // 或者在配置中启用 cfg.EnableLogging = true cfg.LogLevel = "debug"