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

知识点掌握了，还需要不断练习才能熟练运用。下面golang学习网给大家带来一个Golang开发实战，手把手教大家学习《使用golang编写一个并发工作队列》，在实现功能的过程中也带大家重新温习相关知识点，温故而知新，回头看看说不定又有不一样的感悟！

其实golang用一个函数可以构建一个并发队列，现在编写一个灵活可控的队列程序

先定义一个工作

type Worker struct {
    ID      int
    RepJobs chan int64
    SM      *SM
    quit    chan bool
}

包含了workid和执行任务的id，上面的SM只是任务具体内容，这个和具体业务相关，大家自己编写自己的SM业务逻辑

然后定义工作池

type workerPool struct {
    workerChan chan *Worker
    workerList []*Worker
}

这个里面定义了一个工作队列的切片，可以自定义工作队列的个数，甚至后期还可以添加work，还定义了一个队列类型的管道。

定义完成过后就可以初始化工作池了

func InitWorkerPool() error {
    n := 3
    WorkerPool = &workerPool{
        workerChan: make(chan *Worker, n),
        workerList: make([]*Worker, 0, n),
    }
    for i := 0; i 

<p>这个里面我写死了worker的个数是3，当然这个可以通过读取配置文件或者参数传递的方式；这个里面逐一启动work</p>
<h2>worker.Start()，这个是关键</h2>

<pre class="brush:plain;">
func (w *Worker) Start() {
    go func() {
        for {
            WorkerPool.workerChan 

<p>这个就是go 启动一个协程，先把自己放到workerChan中，然后不断从w.RepJobs管道中获取任务并执行，如果执行完成后又把自己放回到队列中。</p>
<h2>所以如果你要有任务需要执行，放到这个管道中即可</h2>

<pre class="brush:plain;">
func Dispatch() {
    for {
        select {
        case job := 

<p>从管道中拿出一个worker并把任务id放到worker中去执行。</p>
<h2>当然你可以停止worker，甚至可以停止job</h2>

<pre class="brush:plain;">
func (w *Worker) Stop() {
    go func() {
        w.quit 

<p><strong>补充一下，int64和字符串转换。</strong></p>
<p>string到int</p>

<pre class="brush:plain;">
int,err:=strconv.Atoi(string)

string到int64

int64, err := strconv.ParseInt(string, 10, 64)

int到string

string:=strconv.Itoa(int)

int64到string

string:=strconv.FormatInt(int64,10)

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

以上就是本文的全部内容了，是否有顺利帮助你解决问题？若是能给你带来学习上的帮助，请大家多多支持golang学习网！更多关于Golang的相关知识，也可关注golang学习网公众号。