golang使用chan限制多协程单位时执行次数

发布时间：August 10, 2017 // 分类： // No Comments

限制单位时间内执行次数，并保持先后顺序。

package main

import "fmt"
import "time"

var c chan chan int

func worker(i int) {
        t := make(chan int)
        c <- t
        fmt.Println(i, "启动任务")
loop:
        for {
                select {
                case <-t:
                        fmt.Println(i)
                        break loop
                default:
                        fmt.Println(i, "等待可用")
                        time.Sleep(100 * time.Millisecond)
                }
        }

        fmt.Println(i, "开始任务")
}
func master() {
        for {
                for i := 0; i < 10; i++ {
                        t := <-c
                        t <- 1
                        time.Sleep(500 * time.Millisecond)
                }
        }
}

func main() {
        c = make(chan chan int, 20)
        for i := 0; i < 10; i++ {
                go worker(i)
                time.Sleep(500 * time.Millisecond)
        }
        go master()
        for {
                time.Sleep(1000 * time.Millisecond)

        }
}

标签：none

海运的博客

golang使用chan限制多协程单位时执行次数

评论已关闭

分类

最新文章

最近回复