其实golang用一个函数可以构建一个并发队列,现在编写一个灵活可控的队列程序
先定义一个工作
包含了workid和执行任务的id,上面的sm只是任务具体内容,这个和具体业务相关,大家自己编写自己的sm业务逻辑
然后定义工作池
这个里面定义了一个工作队列的切片,可以自定义工作队列的个数,甚至后期还可以添加work,还定义了一个队列类型的管道。
定义完成过后就可以初始化工作池了
这个里面我写死了worker的个数是3,当然这个可以通过读取配置文件或者参数传递的方式;这个里面逐一启动work
worker.start(),这个是关键
这个就是go 启动一个协程,先把自己放到workerchan中,然后不断从w.repjobs管道中获取任务并执行,如果执行完成后又把自己放回到队列中。
所以如果你要有任务需要执行,放到这个管道中即可
从管道中拿出一个worker并把任务id放到worker中去执行。
当然你可以停止worker,甚至可以停止job
补充一下,int64和字符串转换。
string到int
string到int64
int到string
int64到string
以上为个人经验,希望能给大家一个参考,也希望大家多多支持www.887551.com。如有错误或未考虑完全的地方,望不吝赐教。
黄山市民网:https://www.huangshanshimin.com/