Home

PowerThreadPool

Enables efficient thread pool management with callback implementation, granular control, customizable concurrency, and support for diverse task submissions.

Download

PowerThreadPool is available as Nuget Package now.
Support: Net46+ | Net5.0+

Features

• Pool Control | Work Control
  • Stop
  • Pause
  • Resume
  • Force Stop
  • Wait
  • Cancel
• Work Dependency
• Thread Pool Sizing
  • Idle Thread Scheduled Destruction
  • Thread Starvation Countermeasures (Long-running Task Support)
• Work Priority | Thread Priority
• Work Timeout | Cumulative Work Timeout
• Work Callback | Default Callback
• Error Handling
• Runtime Status
• Load Balancing

Getting started

Simple example: run a work

PowerPool powerPool = new PowerPool(new PowerPoolOption() { /* Some options */ });
powerPool.QueueWorkItem(() => 
{
    // DO SOMETHING
});

With callback

PowerPool powerPool = new PowerPool(new PowerPoolOption() { /* Some options */ });
powerPool.QueueWorkItem(() => 
{
    // DO SOMETHING
    return result;
}, (res) => 
{
    // Callback of the work
});

With option

PowerPool powerPool = new PowerPool(new PowerPoolOption() { /* Some options */ });
powerPool.QueueWorkItem(() => 
{
    // DO SOMETHING
    return result;
}, new WorkOption()
{
    // Some options
});

Reference

string QueueWorkItem(Action action, *);
string QueueWorkItem(Action<object[]> action, object[] param, *);
string QueueWorkItem<T1, ...>(Action<T1, ...> action, T1 param1, ..., *);
string QueueWorkItem<T1, ..., TResult>(Func<T1, ..., TResult> function, T1 param1, ..., *);
string QueueWorkItem<TResult>(Func<TResult> function, *);
string QueueWorkItem<TResult>(Func<object[], TResult> function, object[] param, *);

• Asterisk (*) denotes an optional parameter, either a WorkOption or a delegate (Action<ExecuteResult<object>> or Action<ExecuteResult<TResult>>), depending on whether the first parameter is an Action or a Func.
• In places where you see ellipses (...), you can provide up to five generic type parameters.

APIs

API Summary

• PowerPool

• ExecuteResult

• PowerPoolOption

• DestroyThreadOption

• WorkOption

• TimeoutOption