TaskHandler 1.0.3

<img src="https://raw.githubusercontent.com/jchristn/TaskHandler/main/Assets/logo.png" width="250" height="250">

TaskHandler

A simple C# class library to help manage running a queue of tasks without relinquishing control.

New in v1.0.x

• Initial release

Feedback or Issues

Encounter a bug? Think of a way this library could be even better? Please file an issue here!

Test App

Please refer to the Test project for a full example of how to exercise the class library.

Example

using TaskHandler;

TaskQueue queue = new TaskQueue();      // allow up to 32 concurrent tasks
TaskQueue queue = new TaskQueue(16);    // allow up to 16 concurrent tasks

queue.AddTask(
  Guid.NewGuid(),                       // unique identifier
  "Task 1",                             // name for the task
  new Dictionary<string, object>(),     // any metadata you like!
  delegate(CancellationToken token) {   // your task in form of Action<CancellationToken>
  	Console.WriteLine("Task 1 starting!");
  	Task.Delay(10000).Wait();
  	Console.WriteLine("Task 1 ending!");
  });

queue.AddTask(
  Guid.NewGuid(),                       // unique identifier
  "Task 2",                             // name for the task
  new Dictionary<string, object>(),     // any metadata you like!
  delegate(CancellationToken token) {   // your task in form of Action<CancellationToken>
  	Console.WriteLine("Task 2 starting!");
  	Task.Delay(5000).Wait();
  	Console.WriteLine("Task 2 ending!");
  });

queue.Start();
Console.WriteLine(queue.RunningCount);  // Integer, the number of running tasks
queue.Stop([guid]);                     // Cancel a specific task
queue.Stop();                           // Cancel all tasks

For Control Freaks

queue.Logger = Console.WriteLine;       // For debug messages
queue.OnTaskAdded += ...                // When a task is added
queue.OnTaskStarted += ...              // When a task starts
queue.OnTaskFinished += ...             // When a task finishes
queue.OnTaskFaulted += ...              // When a task faults
queue.OnTaskCanceled += ...             // When a task is canceled
queue.OnProcessingStarted += ...        // When the task queue is started
queue.OnProcessingStopped += ...        // When the task queue is stopped

Run a Task with a Timeout

string result;

result = await TaskRunWithTimeout.Go(
    Task.Run(async () =>
    { 
        await Task.Delay(1000); 
        return "hello!";
    }), 
    2500); 
// hello!

result = await TaskRunWithTimeout.Go(
    Task.Run(async () =>
    { 
        await Task.Delay(5000); 
        return "hello!"; 
    }), 
    2500);
// TimeoutException thrown

Version History

Please refer to CHANGELOG.md for version history.