ParallelBudget

public static class ParallelBudget

Thread count utility for balancing thread usage involving nested loops that are all participating in the threadpool. Components which run multithreaded code within their iterated Process() methods should try and use the threading tools in this class lest they explode the thread usage.

Methods

For

public static void For(int fromInclusive, int toExclusive, CancellationToken token, Action<int> body)

Run a loop using the threads available to the current thread.

Parameters:

fromInclusive (int)
toExclusive (int)
token (CancellationToken)
body (Action<int>)

For

public static void For(int fromInclusive, int toExclusive, int maxDegree, int budget, CancellationToken token, Action<int> body)

Run a loop on at most maxDegree threads, sharing the budget among the loop bodies and anything nested inside them.

Parameters:

fromInclusive (int)
toExclusive (int)
maxDegree (int)
budget (int)
token (CancellationToken)
body (Action<int>)

For<TLocal>

public static void For<TLocal>(int fromInclusive, int toExclusive, CancellationToken token, Func<TLocal> localInit, Func<int, TLocal, TLocal> body, Action<TLocal> localFinally)

Run a loop with per-thread state using the threads available to the current thread.

Parameters:

fromInclusive (int)
toExclusive (int)
token (CancellationToken)
localInit (Func<TLocal>)
body (Func<int, TLocal, TLocal>)
localFinally (Action<TLocal>)