[#33] util: Define worker pool interface

Signed-off-by: Leonard Lyubich <leonard@nspcc.ru>
This commit is contained in:
Leonard Lyubich 2020-09-21 12:49:33 +03:00 committed by Alex Vanin
parent d3b5ff9526
commit d52bdb27c5

24
pkg/util/worker_pool.go Normal file
View file

@ -0,0 +1,24 @@
package util
// WorkerPool represents the tool for control
// the execution of go-routine pool.
type WorkerPool interface {
// Submit queues a function for execution
// in a separate routine.
//
// Implementation must return any error encountered
// that prevented the function from being queued.
Submit(func()) error
}
// SyncWorkerPool represents synchronous worker pool.
type SyncWorkerPool struct{}
// Submit executes passed function immediately.
//
// Always returns nil.
func (SyncWorkerPool) Submit(fn func()) error {
fn()
return nil
}