PowerThreadPool 4.22.5

PowerThreadPool

A comprehensive and efficient lock-free thread pool with granular work control, flexible concurrency, robust error handling, and easy work management for both sync and async workloads.

Documentation

Access the Wiki in English | 中文 | 日本語.
Visit the DeepWiki for more information.

Pack

powershell -File build.ps1 -Version {Version}

Installation

If you want to include PowerThreadPool in your project, you can install it directly from NuGet.
Support: Net40+ | Net5.0+ | netstandard2.0+

Features

• Sync | Async
• Pool Control | Work Control
  • Stop
  • Pause
  • Resume
  • Force Stop
  • Wait
  • Fetch
  • Cancel
• Divide And Conquer
• Thread Pool Sizing
  • Idle Thread Scheduled Destruction
  • Thread Starvation Countermeasures (Long-running Work Support)
• Work Callback | Default Callback
• Rejection Policy
• Parallel Execution
  • For
  • ForEach
  • Watch
• Work Priority | Thread Priority
• Error Handling
  • Retry
• Work Timeout | Cumulative Work Timeout
• Work Dependency
• Work Group
  • Group Control
  • Group Relation
• Events
• Runtime Status
• Running Timer
• Queue Type (FIFO | LIFO | Custom)
• Load Balancing
• Lock-Free

Getting started

Out-of-the-box: Run a simple work

PowerThreadPool is designed to be out-of-the-box. For simple works, you can get started without any complex configuration.

PowerPool powerPool = new PowerPool();
// Sync
powerPool.QueueWorkItem(() => 
{
    // Do something
});
// Async
powerPool.QueueWorkItemAsync(async () =>
{
    // Do something
    // await ...;
});

With callback

PowerPool powerPool = new PowerPool(new PowerPoolOption() { /* Some options */ });
// Sync
powerPool.QueueWorkItem(() => 
{
    // Do something
    return result;
}, (res) => 
{
    // Callback of the work
});
// Async
powerPool.QueueWorkItemAsync(async () =>
{
    // Do something
    // await ...;
}, (res) =>
{
    // Callback of the work
});

With option

PowerPool powerPool = new PowerPool(new PowerPoolOption() { /* Some options */ });
// Sync
powerPool.QueueWorkItem(() => 
{
    // Do something
    return result;
}, new WorkOption()
{
    // Some options
});
// Async
powerPool.QueueWorkItemAsync(async () =>
{
    // Do something
    // await ...;
}, new WorkOption()
{
    // Some options
});

Reference

string QueueWorkItem<T1, ...>(Action<T1, ...> action, T1 param1, ..., *);
string QueueWorkItem(Action action, *);
string QueueWorkItem(Action<object[]> action, object[] param, *);
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, *);
string QueueWorkItemAsync(Func<Task> asyncFunc, *);
string QueueWorkItemAsync<TResult>(Func<Task<TResult>> asyncFunc, *);
string QueueWorkItemAsync(Func<Task> asyncFunc, out Task task, *);
string QueueWorkItemAsync<TResult>(Func<Task<TResult>> asyncFunc, out Task<ExecuteResult<TResult>> task, *);

• 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.

More

Testing And Performance Analysis | Feature Comparison
Get involved: Join our growing community

Contributors ✨

Thanks goes to these wonderful people (emoji key):

<table> <tbody> <tr> <td align="center" valign="top" width="14.28%"><a href="https://github.com/dlnn"><img src="https://avatars.githubusercontent.com/u/22004270?v=4?s=100" width="100px;" alt="一条咸鱼"/><br />_{<b>一条咸鱼</b>}</a><br /><a href="https://github.com/ZjzMisaka/PowerThreadPool/commits?author=dlnn" title="Code">💻</a></td> <td align="center" valign="top" width="14.28%"><a href="https://github.com/ZjzMisaka"><img src="https://avatars.githubusercontent.com/u/16731853?v=4?s=100" width="100px;" alt="ZjzMisaka"/><br />_{<b>ZjzMisaka</b>}</a><br /><a href="https://github.com/ZjzMisaka/PowerThreadPool/commits?author=ZjzMisaka" title="Code">💻</a> <a href="#maintenance-ZjzMisaka" title="Maintenance">🚧</a> <a href="https://github.com/ZjzMisaka/PowerThreadPool/commits?author=ZjzMisaka" title="Documentation">📖</a></td> <td align="center" valign="top" width="14.28%"><a href="https://github.com/r00tee"><img src="https://avatars.githubusercontent.com/u/32619657?v=4?s=100" width="100px;" alt="r00tee"/><br />_{<b>r00tee</b>}</a><br /><a href="#ideas-r00tee" title="Ideas, Planning, & Feedback">🤔</a></td> <td align="center" valign="top" width="14.28%"><a href="https://github.com/aadog"><img src="https://avatars.githubusercontent.com/u/18098725?v=4?s=100" width="100px;" alt="aadog"/><br />_<b>aadog</b></a><br /><a href="https://github.com/ZjzMisaka/PowerThreadPool/issues?q=author%3Aaadog" title="Bug reports">🐛</a></td> <td align="center" valign="top" width="14.28%"><a href="https://github.com/RookieZWH"><img src="https://avatars.githubusercontent.com/u/17580767?v=4?s=100" width="100px;" alt="RookieZWH"/><br />_{<b>RookieZWH</b>}</a><br /><a href="#question-RookieZWH" title="Answering Questions">💬</a></td> <td align="center" valign="top" width="14.28%"><a href="https://github.com/hebinary"><img src="https://avatars.githubusercontent.com/u/86285187?v=4?s=100" width="100px;" alt="hebinary"/><br />_{<b>hebinary</b>}</a><br /><a href="#question-hebinary" title="Answering Questions">💬</a></td> </tr> </tbody> </table>

This project follows the all-contributors specification. Contributions of any kind welcome!