现在在做的项目有一个需求是,项目启动的时候将一个线程池启动,并且在线程池启动成功后各个业务模块往里面按顺序地塞入定时任务;
感觉这种需求最优雅的实现方式就是用 channel ,但是网上找了半天,最接近的方式也就是使用 BlockingQueue 封装一个,实际实现的功能差远了(比如对于超时场景的处理)。本站也找到了类似的提问帖( https://www.v2ex.com/t/671917 )但是没有在评论区找到答案。
项目虽然有引入消息队列,但是感觉这种场景上消息队列实在是太沉重了,恐怕有些太过于拼命了(?
1
defaw 2024-07-25 10:52:10 +08:00
kotlin 协程的 channel ,但是并不能像 go 一样 select
|
2
busln 2024-07-25 17:21:07 +08:00
轻量使用的话,redis 可以
|