producerConsumer

type CBaseInfo struct {

	// 记录内部日志信息
	Record func(tag string, msg interface{})
	// contains filtered or unexported fields
}

type Config struct {

	// * channel型(ChannelType)：基于缓冲channel队列实现的。
	// * cache型(CacheType)：基于redis型队列实现的。
	Type ContainerType

	// 消费信息的函数
	// 信息体最终落到此函数处理
	// 由用户自定义函数实体内容
	ConsumeFunc func(IMessage)

	// 消息队列长度
	//  如果为channel型，此变量为int类型。请自行处理不一致。
	MsgLen int64

	// 空闲存活时间（针对AssistRunner）,单位为秒（s）
	//   如果是redis型的，此值等同于ReadTimeout。
	AssistIdleKeepAlive int64

	// 记录内部日志信息
	Record func(tag string, msg interface{})

	// redis 队列名字（唯一标识）
	//  针对redis型
	CacheListKey string

	// 把redis队列中的字符串信息解析成相应的信息结构体
	//  针对redis型
	Unmarshal func([]byte) (IMessage, error)

	// 把信息结构体序列化成字符串，以便保存到redis队列中
	//  针对redis型
	Marshal func(IMessage) ([]byte, error)

	// redis 操作实例 实现接口IRedis
	//  针对redis型
	CacheInstance ICache
}

type Container struct {
	CBaseInfo
	// contains filtered or unexported fields
}

type ContainerRedis struct {
	CBaseInfo

	// 把Cache队列中的字符串信息解析成相应的信息结构体
	Unmarshal func([]byte) (IMessage, error)

	// 把信息结构体序列化成字符串，以便保存到Cache(如：redis)队列中
	Marshal func(IMessage) ([]byte, error)

	// 读取信息列表超时时间(秒)
	//  如果列表没有元素会阻塞列表直到等待超时
	ReadTimeout int64

	// 信息队列长度。
	// 如果为零，代表程序不限制（则以Cache(如：redis)的队列最大限制为准）
	// 但不保证真正Cache(如：redis)队列长度一定会小于此值。
	// 另外，此值关系到是否有协助协程产生。
	MsgLen int64

	// cache 队列名字（唯一标识）
	CacheListKey string
	// contains filtered or unexported fields
}

type ContainerType string

type ICache interface {
	// BLPOP key1 timeout(秒)
	// 移出并获取列表的第一个元素，
	// 如果列表没有元素会阻塞列表直到等待超时或发现可弹出元素为止。
	BLPop(key string, timeout int64) (map[string]string, error)

	// 在列表尾部中添加一个或多个值
	RPush(key string, values ...interface{}) (int64, error)

	// 获取列表长度
	LLen(key string) (int64, error)
}

type IContainer interface {
	// 生产消息
	Produce(msg IMessage) error
	// 消费消息
	Consume() error
	// 消费消息的协程数目
	NumGoroutine() (master, assistActive int64)
}

type IMessage interface {
	// 标识
	// 此字段不能为空，
	// 否则会被当做无效数据抛弃。
	// 容器不对此标识的唯一性感兴趣。
	// 用户可以自行确保此标识的唯一性
	Id() string
}