TaskSchedulerView 1.73 download the new version for android

Private ReadOnly _tasks As LinkedList(Of Task) = New LinkedList(Of Task)() Private Shared _currentThreadIsProcessingItems As Boolean ' Indicates whether the current thread is processing work items. Public Class LimitedConcurrencyLevelTaskScheduler : Inherits TaskScheduler ' Provides a task scheduler that ensures a maximum concurrency level while

' Wait for the tasks to complete before displaying a completion message.Ĭonsole.WriteLine(vbCrLf + vbCrLf + 'Successful completion.') If outputItem Mod 3 = 0 Then Console.WriteLine() We're done processing items on the current threadįinally ',Ĭonvert.ToChar(i), iteration, ) Execute the task we pulled out of the queue

note that we're done processing, and get out. When there are no more items to be processed, Process all available items in the queue. This is necessary to enable inlining of tasks into this thread. Note that the current thread is now processing work items. Public LimitedConcurrencyLevelTaskScheduler(int maxDegreeOfParallelism) Creates a new instance with the specified degree of parallelism. Private int _delegatesQueuedOrRunning = 0 Indicates whether the scheduler is currently processing work items. Private readonly int _maxDegreeOfParallelism The maximum concurrency level allowed by this scheduler. Use our factory to run a set of tasks.įor (int outer = 0 outer _tasks = new LinkedList() // protected by lock(_tasks) TaskFactory factory = new TaskFactory(lcts) ĬancellationTokenSource cts = new CancellationTokenSource() Create a TaskFactory and pass it our custom scheduler.

LimitedConcurrencyLevelTaskScheduler lcts = new LimitedConcurrencyLevelTaskScheduler(2) Create a scheduler that uses two threads. It then launches two sets of tasks and displays information about the task and the thread on which the task is executing. The following example creates a custom task scheduler that limits the number of threads used by the app.

TaskSchedulerView 1.73 download the new version for android