diff options
| author | mo khan <mo@mokhan.ca> | 2009-10-23 13:09:04 -0600 |
|---|---|---|
| committer | mo khan <mo@mokhan.ca> | 2009-10-23 13:09:04 -0600 |
| commit | 9a3430b2a1f0445c0dbac703907762e225383421 (patch) | |
| tree | 751d5742a199eae57ebb6d767e650bd6c803bdc3 /product/service.infrastructure/threading/CommandProcessor.cs | |
| parent | f76fe6ca01f3dc5fabc8bf16f299420ba9d7ef05 (diff) | |
renamed some components to something that is more descriptive.main
Diffstat (limited to 'product/service.infrastructure/threading/CommandProcessor.cs')
| -rw-r--r-- | product/service.infrastructure/threading/CommandProcessor.cs | 32 |
1 files changed, 4 insertions, 28 deletions
diff --git a/product/service.infrastructure/threading/CommandProcessor.cs b/product/service.infrastructure/threading/CommandProcessor.cs index 7c7b195..170ec4c 100644 --- a/product/service.infrastructure/threading/CommandProcessor.cs +++ b/product/service.infrastructure/threading/CommandProcessor.cs @@ -1,37 +1,13 @@ using System; -using System.Collections.Generic; using System.Linq.Expressions; using gorilla.commons.utility; namespace MoMoney.Service.Infrastructure.Threading { - public class CommandProcessor : ICommandProcessor + public interface CommandProcessor : Command { - readonly Queue<Command> queued_commands; - - public CommandProcessor() - { - queued_commands = new Queue<Command>(); - } - - public void add(Expression<Action> action_to_process) - { - add(new AnonymousCommand(action_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 stop() - { - queued_commands.Clear(); - } + void add(Expression<Action> action_to_process); + void add(Command command_to_process); + void stop(); } }
\ No newline at end of file |
