diff options
Diffstat (limited to 'lib/infrastructure/threading/SynchronousCommandProcessor.cs')
| -rw-r--r--[-rwxr-xr-x] | lib/infrastructure/threading/SynchronousCommandProcessor.cs | 58 |
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 + } +} |
