pool: 重构去除 OnDemandBlockTaskPool 中的 context.Context 字段 about ekit HOT 5 CLOSED

之所以用ctx是想表达在成功调用ShutdownNow那一刻,所有处于“可中断上下文”中的go协程均能收到中断信号.这其中不仅包括了schedulingTasks任务调度循环,还包括那些运行中且内部监听了ctx信号的Task

func (b *OnDemandBlockTaskPool) schedulingTasks() {
                                  // .....

				// 这里向task传递的正是那个ctx,对于那些在内部监听了ctx.Done()的Task
                                  // 使其以自定义方式更快速地中断运行
				err := task.Run(b.ctx)
				if err != nil {
					return
				}
			}()
		}
	}
}

https://github.com/gotomicro/ekit/blob/dev/pool/task_pool.go#L253

from ekit.

👍
我试了一下别的方式，比如说使用 channel，确实不如这种方法好。

from ekit.

@longyue0521 @flycash 有几点疑问，请大佬指点：
1、NewOnDemandBlockTaskPool时用户必须使用WithQueueBacklogRate这个options来设置queueBacklogRate吗?否则if判断queueBacklogRate默认值为0，会创建失败吧？

2、372行注释不对吧（刚启动的协程除非恰巧赶上Shutdown/ShutdownNow被调用，否则应该至少执行一个task），如果initGo是10，用户只提交了2个任务，那剩余8个goroutine不会执行任务，所以不会至少执行一个task吧

from ekit.

@kangdan6

1. 既然设置为options,必然是可选的.即用户不通过WithXXXOption指定,在New的时候会提供默认值. 你可以看一下对应的测试代码,也可以在本地构造一个不设置queueBacklogRate而使NewOnDemandBlockTaskPool失败的测试用例
2. 这个注释是用来说明,为什么刚刚创建idleTimer就要将其关闭,因为刚创建出来的协程很可能直接走for循环中的case <-idleTimer.C分支而退出. 那么这样耗时、耗资源创建出的协程却什么都没干是没有意义的.你举的用例是因为提供足够的任务,但也确实反映出该注视确实会引起歧义.你可以提交一个issue修改/完善该注释.

from ekit.

from ekit.