Mega Code Archive

 

Categories / C# / Collections Data Structure

 

Task queue

using System.Collections.Generic; using System.Threading; namespace PS.WSSDeploy.VSAddin.Utils {     public interface Task     {         void TaskExecute();     }     public class TaskQueue     {         private readonly Queue<Task> queue = new Queue<Task>();         public void Enqueue(Task task)         {             lock (queue)             {                 queue.Enqueue(task);                 if (queue.Count == 1) RunTaskInThreadPool();             }         }         public void Clear()         {             lock (queue)             {                 queue.Clear();             }         }         private void RunTaskInThreadPool()         {             ThreadPool.QueueUserWorkItem(Execute);         }         private void Execute(object state)         {             Task task = null;             lock (queue)             {                 if (queue.Count > 0)                     task = queue.Peek();             }             if (task != null)             {                 task.TaskExecute();             }             lock (queue)             {                 if (queue.Count > 0)                 {                     queue.Dequeue();                 }                 if (queue.Count > 0)                 {                     RunTaskInThreadPool();                 }             }         }     } }