Background work utilities for .NET Core apps based on Hosted services. Background work queue, shared resource access queue, background data processing conveyor.
AccessFactory for creating simple access instances from delegates
IConveyorMachine<TData, TResult> for conveyor data processing machines
IActivatable and IThrottling for shared resources and conveyor machines with particular usage strategies
Service interfaces
IWorkQueue and IPriorityWorkQueue for background task queue
IAccessQueue<TResource> and IPriorityAccessQueue<TResource> for shared resource access queue
IConveyor<TData, TResult> and IPriorityConveyor<TData, TResult> for background data processing conveyor
Helpers and extensions including methods to use services together (eg. enqueue IAccess<TResource> to IWorkQueue) if needed
AInq.Background
Queues and conveyor implementations.
Background work queue
Optional support for configurable parallelism
Optional support for prioritizing
Use WorkQueueInjection to regiter service or create for internal usage
Shared resource access queue
Support single or many resource instances with different lifetime
Optional support for prioritizing
Use AccessQueueInjection to regiter service or create for internal usage
Background data processing conveyor
Support single or many conveyor machines with different lifetime
Optional support for prioritizing
Use ConveyorInjection to regiter service or create for internal usage
You can extend functionality by implementing custom ITaskWrapper, ITaskManager or ITaskProcessor and combine with existing ones to create more service variants.
AInq.Background.Scheduler.Abstraction
Work scheduler interfaces and helpers library.
Service interfaces
IWorkScheduler for background work scheduler
Helpers and extensions including methods to use services together (eg. schedule IAccess<TResource> to IWorkScheduler) if needed
AInq.Background.Scheduler
Work scheduler implementation.
Support delayed, time-scheduled, and cron-scheduled work
Use WorkSchedulerInjection to regiter service or create for internal usage
You can extend functionality by implementing custom IScheduledTaskWrapper or IWorkSchedulerManager and combine with existing ones to create more service variants.
NOTE:Cronos is used for parsing Cron expressions - follow documentation for supported options. Format with seconds is supported.
AInq.Background.Enumerable
NEW Batch processing extensions for IWorkQueue, IAccessQueue<TResource> and IConveyor<TData, TResult>
AInq.Background.Startup
NEW Startup work utility for running some work before host start
Support interaction with background work queue
Documentation
As for now documentation is provided in this document and by XML documentation inside packages.
Contribution
These packages are in active production use, all fixes and improvements will be published after some internal testing.
If you find a bug, have a question or something else - you are friendly welcome to open an issue.
