csharp-forallp

C# IEnumerable.ForAll, on steroids: parallel and with progress handlers.

ForAllP is an extension method to the IEnumerable<T> interface.

Similar to ForAll, it executes some code on each item of a collection:

• In parallel. Right now, the number of concurrent threads is managed by the runtime library.
• With progress handling. Five callbacks are provided:
  • Total start
  • Item start
  • Item progress
  • Item log
  • Item finished
  • Total finished

ForAllP allows the developer to process a collection of items in parallel and provide actions (anonymous functions) that can update the UI, all in the same function call. No delegates, events or the like.

Install

Right now, you have to copy and paste the code in ForAllP.cs into your project.

It is planned to create a nuget package.

Usage

string[] data = new string[] { "012", "123", "234", "345", "456", "567", "678", "789", "890", "901" };

Random rnd = new Random();

data.ForAllP(
	body: (x, callback_percentage, callback_log) => {
		callback_percentage(0);
		Thread.Sleep(rnd.Next(500, 1000));
		callback_percentage(25);
		Thread.Sleep(rnd.Next(500, 1000));
		callback_log("Halfway!");
		Thread.Sleep(rnd.Next(500, 1000));
		callback_percentage(75);
		Thread.Sleep(rnd.Next(500, 1000));
		callback_percentage(100);
	},
	item_progress: (x, n, t, p) => {
		Console.WriteLine(string.Format("Item progress: {0} ({1}/{2}): {3:P2}", x.ToString(), n, t, p / 100));
	},
	item_log: (x, n, t, l) => {
		Console.WriteLine(string.Format("Item log: {0} ({1}/{2}): {3}", x.ToString(), n, t, l));
	},
	item_started: (x, n, t) => {
		Console.WriteLine(string.Format("Item started: {0} ({1}/{2})", x.ToString(), n, t));
	},
	item_finished: (x, n, t) => {
		Console.WriteLine(string.Format("Item finished: {0} ({1}/{2})", x.ToString(), n, t));
	},
	total_started: () => {
		Console.WriteLine("Start.");
	},
	total_finished: () => {
		Console.WriteLine("End.");
	}
);

For the sake of simplicity, it does not appear in the code above, but please do not forget to add this two lines at the end of every progress handler:

Refresh();
Application.DoEvents();

and also this line at the beginning of the total_finished progress handler:

Application.DoEvents();

Change log

Please see the CHANGELOG for more information what has changed recently.

Testing

Contributing

Please see CONTRIBUTING and CONDUCT for details.

Security

If you discover any security related issues, please email DM @jotaelesalinas instead of using the issue tracker.

To do

• Add some comments
• Add tests
• Add item log event
• Add different signatures to allow simpler body parameters without callbacks or only one
• Create external nuget package
• Add option to make it async
• Add option to limit number of threads

Credits

• José Luis Salinas
• All Contributors

License

The MIT License (MIT). Please see License File for more information.