使用golang编写一个并发工作队列

其实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

以上为个人经验，希望能给大家一个参考，也希望大家多多支持。如有错误或未考虑完全的地方，望不吝赐教。