monoprocess

Documentation

Index

• func NewMonoprocessBackend(b backend.Backend) *monoprocessBackend

Functions

func NewMonoprocessBackend

func NewMonoprocessBackend(b backend.Backend) *monoprocessBackend

NewMonoprocessBackend wraps an existing backend and improves its responsiveness in case the backend and worker are running in the same process. This backend uses channels to notify the worker every time there is a new task ready to be worked on. Note that only one worker will be notified. IMPORTANT: Only use this backend when the backend and worker are running in the same process.