2using System.Collections.Generic;
10 internal static class MqTasks
12 private static readonly ManualResetEvent terminating =
new ManualResetEvent(
false);
13 private static readonly LinkedList<MqTaskThread> threads =
new LinkedList<MqTaskThread>();
14 private static bool terminated =
false;
18 Model.OnFinalizing += Model_OnFinalizing;
21 private static void Model_OnFinalizing(
object sender, EventArgs e)
27 internal static void ExecuteTask(MqTask Item)
36 if (threads.First is
null)
40 T = threads.First.Value;
41 threads.RemoveFirst();
46 T =
new MqTaskThread(terminating);
51 internal static void Idle(MqTaskThread Thread)
55 threads.AddLast(Thread);