summaryrefslogtreecommitdiff
path: root/lib/infrastructure/threading/SynchronousCommandProcessor.cs
diff options
context:
space:
mode:
Diffstat (limited to 'lib/infrastructure/threading/SynchronousCommandProcessor.cs')
-rw-r--r--[-rwxr-xr-x]lib/infrastructure/threading/SynchronousCommandProcessor.cs58
1 files changed, 29 insertions, 29 deletions
diff --git a/lib/infrastructure/threading/SynchronousCommandProcessor.cs b/lib/infrastructure/threading/SynchronousCommandProcessor.cs
index 051fedd..c3263f2 100755..100644
--- a/lib/infrastructure/threading/SynchronousCommandProcessor.cs
+++ b/lib/infrastructure/threading/SynchronousCommandProcessor.cs
@@ -1,36 +1,36 @@
-using System;
-using System.Collections.Generic;
-using gorilla.utility;
-
-namespace gorilla.infrastructure.threading
+using System;
+using System.Collections.Generic;
+using jive.utility;
+
+namespace jive.infrastructure.threading
{
- public class SynchronousCommandProcessor : CommandProcessor
- {
- readonly Queue<Command> queued_commands;
+ public class SynchronousCommandProcessor : CommandProcessor
+ {
+ readonly Queue<Command> queued_commands;
- public SynchronousCommandProcessor()
- {
- queued_commands = new Queue<Command>();
- }
+ public SynchronousCommandProcessor()
+ {
+ queued_commands = new Queue<Command>();
+ }
- public void add(Action command)
- {
- add(new AnonymousCommand(command));
- }
+ public void add(Action command)
+ {
+ add(new AnonymousCommand(command));
+ }
- public void add(Command command_to_process)
- {
- queued_commands.Enqueue(command_to_process);
- }
+ public void add(Command command_to_process)
+ {
+ queued_commands.Enqueue(command_to_process);
+ }
- public void run()
- {
- while (queued_commands.Count > 0) queued_commands.Dequeue().run();
- }
+ public void run()
+ {
+ while (queued_commands.Count > 0) queued_commands.Dequeue().run();
+ }
- public void stop()
- {
- queued_commands.Clear();
- }
+ public void stop()
+ {
+ queued_commands.Clear();
}
-} \ No newline at end of file
+ }
+}