NewExecutor 创建工具执行器
(config ExecutorConfig)
| 24 | |
| 25 | // NewExecutor 创建工具执行器 |
| 26 | func NewExecutor(config ExecutorConfig) *Executor { |
| 27 | if config.MaxConcurrency <= 0 { |
| 28 | config.MaxConcurrency = 3 // 默认3个并发 |
| 29 | } |
| 30 | if config.DefaultTimeout <= 0 { |
| 31 | config.DefaultTimeout = 60 * time.Second |
| 32 | } |
| 33 | |
| 34 | return &Executor{ |
| 35 | config: config, |
| 36 | semaphore: make(chan struct{}, config.MaxConcurrency), |
| 37 | } |
| 38 | } |
| 39 | |
| 40 | // ExecuteRequest 执行请求 |
| 41 | type ExecuteRequest struct { |