PowerThreadPool 1.2.0

PowerThreadPool

<img src="https://www.nuget.org/Content/gallery/img/logo-header.svg?sanitize=true" height="30px">

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

Download

PowerThreadPool is available as Nuget Package now.

Getting started

Without callback

PowerPool powerPool = new PowerPool(new ThreadPoolOption() { MaxThreads = 3 });
powerPool.QueueWorkItem(() => 
{
    // DO SOMETHING
    return result;
});

With callback

PowerPool powerPool = new PowerPool(new ThreadPoolOption() { MaxThreads = 3 });
powerPool.QueueWorkItem(() => 
{
    // DO SOMETHING
    return result;
}, (res) => 
{
    // this callback of thread
    // running result: res.Result
});

Stop all threads

powerPool.Stop();

Blocks the calling thread until all of the threads terminates.

powerPool.Wait();

Pause threads

PowerPool powerPool = new PowerPool(new ThreadPoolOption());
string id = powerPool.QueueWorkItem(() => 
{
    while (true)
    {
        // Pause here when user call Pause()
        powerPool.PauseIfRequested();
        // DO SOMETHING
    }
});
// DO SOMETHING
powerPool.Pause(id); // Pause by ID
powerPool.Pause(); // Pause all running thread
powerPool.Resume(true); // Resume all thread

API Summary

PowerPool

API List

PowerPool

Properties

ThreadPoolOption ThreadPoolOption; // Get, Set
int WaitingThreadCount; // Get
int WaitingThreadList; // Get
int RunningThreadCount; // Get
int RunningThreadList; // Get

Events

event ThreadPoolStartEventHandler ThreadPoolStart;
event IdleEventHandler Idle;
event ThreadStartEventHandler ThreadStart;
event ThreadEndEventHandler ThreadEnd;

Methods

string QueueWorkItem(Action action, Action<ExcuteResult<object>> callBack = null)

string QueueWorkItem(Action<object[]> action, object[] param, Action<ExcuteResult<object>> callBack = null)

string QueueWorkItem<T1>(Action<T1> action, T1 param1, Action<ExcuteResult<object>> callBack = null)

string QueueWorkItem<T1, T2>(Action<T1, T2> action, T1 param1, T2 param2, Action<ExcuteResult<object>> callBack = null)

string QueueWorkItem<T1, T2, T3>(Action<T1, T2, T3> action, T1 param1, T2 param2, T3 param3, Action<ExcuteResult<object>> callBack = null)

string QueueWorkItem<T1, T2, T3, T4>(Action<T1, T2, T3, T4> action, T1 param1, T2 param2, T3 param3, T4 param4, Action<ExcuteResult<object>> callBack = null)

string QueueWorkItem<T1, T2, T3, T4, T5>(Action<T1, T2, T3, T4, T5> action, T1 param1, T2 param2, T3 param3, T4 param4, T5 param5, Action<ExcuteResult<object>> callBack = null)

string QueueWorkItem<T1, TResult>(Func<T1, TResult> function, T1 param1, Action<ExcuteResult<TResult>> callBack = null)

string QueueWorkItem<T1, T2, TResult>(Func<T1, T2, TResult> function, T1 param1, T2 param2, Action<ExcuteResult<TResult>> callBack = null)

string QueueWorkItem<T1, T2, T3, TResult>(Func<T1, T2, T3, TResult> function, T1 param1, T2 param2, T3 param3, Action<ExcuteResult<TResult>> callBack = null)

string QueueWorkItem<T1, T2, T3, T4, TResult>(Func<T1, T2, T3, T4, TResult> function, T1 param1, T2 param2, T3 param3, T4 param4, Action<ExcuteResult<TResult>> callBack = null)

string QueueWorkItem<T1, T2, T3, T4, T5, TResult>(Func<T1, T2, T3, T4, T5, TResult> function, T1 param1, T2 param2, T3 param3, T4 param4, T5 param5, Action<ExcuteResult<TResult>> callBack = null)

string QueueWorkItem<TResult>(Func<TResult> function, Action<ExcuteResult<TResult>> callBack = null)

string QueueWorkItem<TResult>(Func<object[], TResult> function, object[] param, Action<ExcuteResult<TResult>> callBack = null)

void Wait()

async Task WaitAsync()

void Stop(bool forceStop = false)

async Task StopAsync(bool forceStop = false)

bool Stop(string id, bool forceStop = false)

async Task<bool> StopAsync(string id, bool forceStop = false)

void PauseIfRequested()

void StopIfRequested()

bool CheckIfRequestedStop()

void Pause()

void Resume(bool resumeThreadPausedById = false)

void Pause(string id)

void Resume(string id)

void Cancel()

bool Cancel(string id)

ExcuteResult<TResult>

Properties

TResult Result; // Get
Status Status; // Get
Exception Exception; // Get

Status

enum Status { Succeed, Failed }

ThreadPoolOption

Properties

int MaxThreads; // Get, Set