diff options
| author | mo khan <mo.khan@gmail.com> | 2019-10-20 16:30:37 -0600 |
|---|---|---|
| committer | mo khan <mo.khan@gmail.com> | 2019-10-20 16:30:37 -0600 |
| commit | ddbc87ff5fa56513cf836838b06b08156408ebcf (patch) | |
| tree | 96f7d3f7f9a857d1f532baf001d5c294f0dffecc /lib/infrastructure/threading/AsynchronousCommandProcessor.cs | |
| parent | d9819d134b27a14235a50bd89d3433e6198730c9 (diff) | |
dump legacy items
Diffstat (limited to 'lib/infrastructure/threading/AsynchronousCommandProcessor.cs')
| -rwxr-xr-x | lib/infrastructure/threading/AsynchronousCommandProcessor.cs | 113 |
1 files changed, 113 insertions, 0 deletions
diff --git a/lib/infrastructure/threading/AsynchronousCommandProcessor.cs b/lib/infrastructure/threading/AsynchronousCommandProcessor.cs new file mode 100755 index 0000000..f776ac1 --- /dev/null +++ b/lib/infrastructure/threading/AsynchronousCommandProcessor.cs @@ -0,0 +1,113 @@ +using System;
+using System.Collections.Generic;
+using System.Threading;
+using gorilla.infrastructure.logging;
+using gorilla.utility;
+
+namespace gorilla.infrastructure.threading
+{
+ public class AsynchronousCommandProcessor : CommandProcessor
+ {
+ readonly Queue<Command> queued_commands;
+ readonly EventWaitHandle manual_reset;
+ readonly IList<Thread> worker_threads;
+ bool keep_working;
+
+ static public readonly Command Empty = new EmptyCommand();
+
+ public AsynchronousCommandProcessor()
+ {
+ queued_commands = new Queue<Command>();
+ worker_threads = new List<Thread>();
+ manual_reset = new ManualResetEvent(false);
+ }
+
+ public void add(Action command)
+ {
+ add(new AnonymousCommand(command));
+ }
+
+ public void add(Command command_to_process)
+ {
+ lock (queued_commands)
+ {
+ if (queued_commands.Contains(command_to_process)) return;
+ queued_commands.Enqueue(command_to_process);
+ reset_thread();
+ }
+ }
+
+ public void run()
+ {
+ reset_thread();
+ keep_working = true;
+ var worker_thread = new Thread(run_commands);
+ worker_thread.SetApartmentState(ApartmentState.STA);
+ worker_threads.Add(worker_thread);
+ worker_thread.Start();
+ }
+
+ public void stop()
+ {
+ keep_working = false;
+ manual_reset.Set();
+ //manual_reset.Close();
+ }
+
+ [STAThread]
+ void run_commands()
+ {
+ while (keep_working)
+ {
+ manual_reset.WaitOne();
+ run_next_command();
+ }
+ }
+
+ void run_next_command()
+ {
+ var command = Empty;
+ within_lock(() =>
+ {
+ if (queued_commands.Count == 0)
+ manual_reset.Reset();
+ else
+ command = queued_commands.Dequeue();
+ });
+ safely_invoke(() =>
+ {
+ command.run();
+ });
+ reset_thread();
+ }
+
+ void safely_invoke(Action action)
+ {
+ try
+ {
+ action();
+ }
+ catch (Exception e)
+ {
+ this.log().error(e);
+ }
+ }
+
+ void reset_thread()
+ {
+ within_lock(() =>
+ {
+ if (queued_commands.Count > 0) manual_reset.Set();
+ else manual_reset.Reset();
+ });
+ }
+
+ void within_lock(Action action)
+ {
+ lock (queued_commands)
+ {
+ action();
+ }
+ }
+ }
+}
\ No newline at end of file |