TaskExecutor

TaskExecutor is a .NET 6.0 library that provides a concurrency-controlled task execution framework. It allows you to enqueue tasks and execute them with a specified level of concurrency.

Features

Limited Concurrent Tasks: Restrict the number of tasks running simultaneously.
Automatic Task Execution: Automatically start a new task as soon as one completes.
Concurrency Control: Dynamically adjust the number of concurrent tasks.
Task Queue: Enqueue tasks with unique IDs and execute them asynchronously.
Error Handling: Capture and handle task-specific errors via an event.
Graceful Shutdown: Stop the executor and wait for running tasks to complete.

Getting Started

Prerequisites

.NET 6.0 SDK

Using the Library

To use the TaskExecutor library in your project:

Add a reference to the TaskExecutor project or include the compiled DLL in your application.
Create an instance of the TaskExecutor class and configure it as needed.

Example Test Application

A test application is included in the repository to demonstrate how to use the TaskExecutor library. The test application is located in the TaskExecutorApp project.

Running the Test Application

Open a terminal in the project directory.
Build the solution: dotnet build
Run the test application: dotnet run --project TaskExecutorApp

Example Code

The Program.cs file in the TaskExecutorApp project demonstrates how to use the TaskExecutor library:

var cts = new CancellationTokenSource();
using var executor = new TaskExecutor.TaskExecutor(3, cts.Token);

executor.OnTaskError += (id, ex) => Console.WriteLine($"Task {id} error: {ex.Message}");

for (int i = 0; i < 20; i++)
{
    int id = i;
    executor.EnqueueTask(id, async () =>
    {
        Console.WriteLine($"Task {id} started");
        await Task.Delay(Random.Shared.Next(2000, 5000));
        Console.WriteLine($"Task {id} finished");
    });
}

await Task.Delay(1000);

while (executor.HasRunningTasks)
{
    await Task.Delay(1000);
}
await executor.StopAsync();

xhunter74/task-executorv1.0.0

Get Started

Readme