csharp_threading

gistfile1.txt

using System;
using System.Collections.Concurrent;
using System.Threading;
using System.Threading.Tasks;

class Program
{
    static void Main(string[] args)
    {
        // Create a concurrent queue to store lambda expressions
        ConcurrentQueue<Action> actionQueue = new ConcurrentQueue<Action>();

        for (int i = 0; i < 10; i++)
        {
            int index = i;
            actionQueue.Enqueue(() =>
            {
                Console.WriteLine($"{index}, thread: {Thread.CurrentThread.ManagedThreadId}");
            });
        }

        // Start a new thread to process the queue
        Thread thread = new Thread(() =>
        {
            while (true)
            {
                if (actionQueue.TryDequeue(out Action action))
                {
                    // Execute the lambda expression on the thread pool
                    ThreadPool.QueueUserWorkItem(_ => action());
                }
                else
                {
                    // Sleep for a short duration if the queue is empty
                    Thread.Sleep(100);
                }
            }
        });
        thread.Start();


        Console.WriteLine("Press any key to exit...");
        Console.ReadKey();
    }
}