chanman
Channels are widely used as queues. chanman (Channel Manager) helps you to easily create queue with channel and manage the data in the queue. You don't have to be afraid of panic situations like channel is already closed etc.
Usage
func main() {
var callbackFn chanman.CallbackFn = func(data interface{}) error {
t.Logf("callbackFn: %v", data)
return nil
}
opts := &chanman.Options{
CallbackFn: callbackFn,
Limit: 10,
Worker: 5,
DataSize: 32,
}
ctx, cancel := context.WithCancel(context.Background())
defer cancel()
queue := chanman.New(ctx, opts)
go queue.Listen()
for i := 0; i <= 20; i++ {
queue.Add(fmt.Sprintf("job-%d", i))
}
}
