golang生产者与消费者

使用golang可以很容易实现，生产者与消费者功能。

实现一：（只生产一定数量数据）

//写入专用通道
//一次写10条
func produce(p chan<- int) {
	for i := 0; i < 10; i++ {
		p <- i	//主线程不能产生死锁,所以此处报错
		fmt.Println("send:",i)
	}
}

//消费专用通道
//一次只取10条
func consumer(c <-chan int) {
	for i := 0; i < 10; i++ {
		v := <-c
		fmt.Println("receive:",v)
	}
}

ch := make(chan int)
//只生产和消费10条记录
go produce(ch)
go consumer(ch)

//自动消费
func autoConsumer(ch <-chan int)  {
    for{
        select {
        case   ws:=<-ch:
            fmt.Println( "fmt print",ws)
        default:
            time.Sleep(1000*time.Millisecond)
        }
    }
}

ch := make(chan int)

//持续生产与消费,high起来
go func() {
  for{  //不断生产,一次10条
    produce(ch)
  }
}()
go autoConsumer(ch)

for  {
        //心跳
        time.Sleep(time.Second)
}

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!