PowerThreadPool

Enables efficient ThreadPool management. Features task queuing, thread control, and customizable concurrent execution. Supports diverse task submissions for complex concurrency requirements.

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 } return result; }); // DO SOMETHING powerPool.Pause(id); // Pause by ID powerPool.Pause(); // Pause all running thread powerPool.Resume(true); // Resume all thread

API

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)