.NET parallel tasks executing library.
Pooler.Parallelclass to execute different tasks in limited background threads count.Pooler.Repeaterclass to execute single specific task in limited background threads count with specific rate or infinitely.
PM> Install-Package Pooler
- Basics - create new pool and run tasks
- Add delegate tasks or functions returning results
- Use Pooler events
- Changing threads count at run
- Regulating CPU and resources load
- Ways to create pooler instance
- Repeater instance and single specific task setup
- Stop processing
- Async tasks
// create new threads pool instance for max 10 threads running simultaneously:
Pooler.Parallel pool = Pooler.Parallel.CreateNew(10);
// add 500 anonymous functions to process:
for (int i = 0; i < 500; i++) {
pool.Add(
// any delegate or void to process
(Pooler.Parallel pool) => {
double dummyResult = Math.Pow(Math.PI, Math.PI);
},
// optional - do not run task instantly after adding, run them a few lines later together
false,
// optional - background execution thread priority to execute this task
ThreadPriority.Lowest,
// optional - task is not async (task doesn't use any background threads inside)
false
);
}
// let's process all tasks in 10 simultaneously running threads in background:
pool.StartProcessing();// There is possible to add task as delegate:
pool.Add(delegate {
double dummyResult = Math.Pow(Math.PI, Math.PI);
});
// ... or to add task as any void function accepting first param as Pooler type:
pool.Add((Pooler.Parallel p) => {
double dummyResult = Math.Pow(Math.PI, Math.PI);
});
// ... or to add task as Func<Pooler.Parallel, object> function:
// accepting first param as Pooler type and returning any result:
pool.Add((Pooler.Parallel p) => {
return Math.Pow(Math.PI, Math.PI);
});
// ... then you can pick up returned result in pool.TaskDone event:
pool.TaskDone += (Pooler.Base p, Pooler.TaskDoneEventArgs e)) => {
double dummyResult = (double)e.TaskResult;
};pool.TaskDoneevent is triggered after each task has been executed (successfuly or with exception):
pool.TaskDone += (Pooler.Base p, Pooler.TaskDoneEventArgs e)) => {
Console.WriteLine("Single task has been executed.");
// e.TaskResult [object] - any place for your task result data:
Console.WriteLine("Task returned result: " + e.TaskResult);
// e.RunningTasksCount [Int32]
Console.WriteLine("Currently running executing background threads count: " + e.RunningTasksCount);
// e.ExecutedTasksCount [Int32]
Console.WriteLine("Executed tasks count: " + e.ExecutedTasksCount);
};pool.TaskExceptionevent is triggered immediately when exception inside executing task is catched, before TaskDone event:
pool.TaskException += (Pooler.Base p, Pooler.ExceptionEventArgs e) => {
Console.WriteLine("Catched exception during task execution.");
// e.Exception [Exception]:
Console.WriteLine(e.Exception.Message);
};pool.AllDoneevent is triggered after all tasks in pooler store has been executed:
pool.AllDone += (Pooler.Base p, Pooler.AllDoneEventArgs e) => {
Console.WriteLine("All tasks has been executed.");
// e.Exceptions [List<Exception>]:
Console.WriteLine("Catched exceptions count: " + e.Exceptions.Count);
// e.PeakThreadsCount [Int32]:
Console.WriteLine("Max. running threads peak: " + e.PeakThreadsCount);
// e.ExecutedTasksCount [Int32]:
Console.WriteLine("Successfully executed tasks count: " + e.ExecutedTasksCount);
};There is possible to change processing background threads count at game play any time you want, Pooler is using locks internaly to manage that properly:
pool.SetMaxRunningTasks(
// new threads maximum to process all tasks in background
50,
// optional (true by default), to create and run all new background threads
// imediatelly inside this function call. If false, each new background thread
// to create to fill new maximum will be created after any running thread process
// execute it's current task, so there should not to be that increasing heap..
true
);There is also possible to get currently running maximum. Currently running maximum is not the same as currently running threads count.
int maxThreads = pool.GetMaxRunningTasks();For .NET code, there is CPU load and any other resources load for your threads managed by operating system, so the only option how to manage load from .NET code is to sleep sometime. Then you can have some free system resources for another jobs, for example you need to have another free 20% CPU computation capacity. To manage sleeping and sleeping time in your tasks globaly by pool, you can use this:
- Set up pausing time globaly for all tasks, any time you want, before processing or any time at run to cut CPU or other resources load:
pool.SetPauseMiliseconds(100);
// And you can read it any time of course:
int pausemiliseconds = pool.GetPauseMiliseconds();- Use
pool.Pause();method sometimes in your hard task:
pool.Add((Pooler.Parallel p) => {
double someHardCode1 = Math.Pow(Math.PI, Math.PI);
p.Pause();
double someHardCode2 = Math.Pow(Math.PI, Math.PI);
p.Pause();
double someHardCode3 = Math.Pow(Math.PI, Math.PI);
});Now resources should not to be so bussy as before, try to put there harder code to process, increase pause time or try to use WinForms Test Application.
Create new parallel tasks instance by static factory or by new Pooler.Parallel:
Pooler.Parallel pool;
pool = Pooler.Parallel.CreateNew(10, 100);
pool = new Pooler.Parallel(10, 100);- First (optional) param is max. threads in background to executing all tasks. 10 by default.
- Second (optional) param is pause miliseconds to slow down CPU load or other resources by
pool.Pause();calls inside your tasks, 0 by default.
Create new repeater tasks instance by static factory or by new Pooler.Repeater to process manytimes only one specific call:
Pooler.Repeater pool;
pool = Pooler.Repeater.CreateNew(10, 500, 100);
pool = new Pooler.Repeater(10, 500, 100);- First (optional) param is max. threads in background to executing one specific task. 10 by default.
- Second (optional) param is how many times will be specific task executed. Null means infinite (zero - 0 - doesn't means infinite), then you need to use pool.StopAll(); or pool.StopCurrent(); somewhere in the task body in the future future manualy.
- Third (optional) param is pause miliseconds to slow down CPU load or other resources by
pool.Pause();calls inside your task, 0 by default.
To add only one specific task into Repeater threads pool to execute this single task manytimes in limited background threads count, use:
// Set one specific task into Repeater as delegate:
pool.Set(delegate {
double dummyResult = Math.Pow(Math.PI, Math.PI);
});
// ... or set task as any void function accepting first param as Pooler type:
pool.Set((Pooler.Repeater p) => {
double dummyResult = Math.Pow(Math.PI, Math.PI);
});
// ... or set task as Func<Pooler.Repeater, object> function:
// accepting first param as Pooler type and returning any result:
pool.Set((Pooler.Repeater p) => {
return Math.Pow(Math.PI, Math.PI);
});
// ... then you can pick up returned result as before in pool.TaskDone event:
pool.TaskDone += (Pooler.Base p, Pooler.TaskDoneEventArgs e)) => {
double dummyResult = (double)e.TaskResult;
};There is also possible to use single static instance from Pooler.(Parallel|Repeater)._instance by:
Pooler.Parallel pool = Pooler.Parallel.GetStaticInstance(10, 100);
Pooler.Repeater pool = Pooler.Repeater.GetStaticInstance(10, 500, 100);
// to get the same instance any time again,
// just call it without params:
pool = Pooler.Parallel.GetStaticInstance();
// or:
pool = Pooler.Repeater.GetStaticInstance();First optinal param (true by default) is to heavy abort - all background threads are aborted by bgThread.Abort();, what should be dangerous for your task. So switch this to false to let all running background threads go to their natural task end and than abort.
pool.StopAll(true);To stop only one background thread processing to make threads pool going to end:
pool.StopCurrent(true);To use any other threads or async code in your pool tasks, you need to tell pooler at the end of async task code that you are done by pool.AsyncTaskDone(); or pool.AsyncTaskDone(resultObject);:
pool.Add(
// any delegate or void to process
(Pooler.Parallel pool) => {
// some async code start here:
CustomDownloader client = new CustomDownloader(
"http://example.com/something/what/takes/some/time/to/load"
);
client.Loaded += (object sender, EventArgs e) => {
// not call pool to continue executing
// another tasks by this bg thread:
pool.AsyncTaskDone(sender);
};
client.Load();
},
false,
ThreadPriority.Lowest,
// true - task is async!
true
);
pool.StartProcessing();