海运的博客

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

发表评论

分类
最新文章
最近回复
  • zr: 大佬,这个bash-completion是从哪个源搞到的
  • 姚生: 要要下载
  • 阿东: 我在编译树莓派的时候也遇到同样的问题,后来发现是make menuconfig 的时候忘了带环...
  • crowjin: 你确定这能过滤??不是所有请求都返回空地址::?
  • : linux系统上单个网卡多条宽带拨号获取公网IP,外网可以访问这些IP,有偿! Q:25299...
  • 硅谷少年: 非常有用,感谢分享
  • spartan2: https://dashboard.hcaptcha.com/welcome_accessib...
  • 海运: 应该能,在购买页面先手工跳过cf机器验证,后续一定时间内不更换ip应该不会再次验证。
  • spartan: 大佬斯巴达开启了CF的机器识别验证,请问插件能自动跳过吗? 另外这个脚本有没有简单使用说明,新...
  • vincent: 膜拜大佬