pc

Documentation

Overview

生产者，消费者模型 参考源码：https://github.com/qmhball/pc/blob/master/pc.go 实例说明：https://blog.csdn.net/qmhball/article/details/107234965 这个模型中，生产者一次性产生多份数据，由指定数量的消费者逐个完成，完成后关闭 这个模型中，无法不间断的产生数据给多个消费者完成，需要一次性产生

Index

• type Pool
  • func NewPool(channelLength int, consumerNumber int, produceFunc func(chan<- interface{}), ...) *Pool
  • func (p *Pool) Run()

Types

type Pool

type Pool struct {
	ConsumerNumber int
	ChannelLength  int
	Tasks          chan interface{}
	Consumer       func(interface{})
	Producer       func(chan<- interface{})
	// contains filtered or unexported fields
}

func NewPool

func NewPool(channelLength int, consumerNumber int, produceFunc func(chan<- interface{}), consumeFunc func(interface{})) *Pool

func (*Pool) Run

func (p *Pool) Run()