jiacai2050 / prosumer Goto Github PK

Subscription publishing mode is a special production and consumer mode, so how to write subscription publishing mode (observer mode) using jiacai2050/prosumer

The consumer uses func(ls []interface{}) error which requires that all elements be individually cast:

consumer := func(ls []interface{}) error {
	var items []int
	for _, item := range items {
		items = append(items, item.(int))
	}

	// ...
	return nil
}

Using reflect you could have a dynamic signature (which would be backwards compatible with []interface{}):

consumer := func(ls []int) error {
	fmt.Printf("get %+v \n", ls)
	wg.Add(-len(ls))
	return nil
}

https://www.reddit.com/r/golang/comments/cd14x2/a_producerconsumer_solution_for_golang/etr9drk?utm_source=share&utm_medium=web2x

• make logger as params, if nil, don't log anything.
• make queue private
• force close
• use a timer instead of calling time.After, as you can re-use timers saving allocs.
  Ticker isn't suitable here, as for doWork, which reset last, will be called when batchSize or batchInterval is met.
• received := make([]interface{}, 0, batchSize)
• abstract Coordinator.Start() logic into worker type.
• prosumer.Put(..) return error