Mercurial > hg > orthanc

comparison Core/MultiThreading/ThreadedCommandProcessor.h @ 466:9da3596069b8

Find changesets by keywords (author, files, the commit message), revision number or hash, or revset expression.
handling failed commands
author Sebastien Jodogne <s.jodogne@gmail.com>
date Fri, 12 Jul 2013 12:11:45 +0200
parents 84966299c8f8
children 322c1b497036
comparison
equal deleted inserted replaced
465:7a966b440f19 466:9da3596069b8
44 SharedMessageQueue queue_; 44 SharedMessageQueue queue_;
45 bool done_; 45 bool done_;
46 std::vector<boost::thread*> threads_; 46 std::vector<boost::thread*> threads_;
47 47
48 boost::mutex mutex_; 48 boost::mutex mutex_;
49 bool success_;
49 unsigned int remainingCommands_; 50 unsigned int remainingCommands_;
50 boost::condition_variable processedCommand_; 51 boost::condition_variable processedCommand_;
51 52
52 static void Processor(ThreadedCommandProcessor* that); 53 static void Processor(ThreadedCommandProcessor* that);
53 54
57 ~ThreadedCommandProcessor(); 58 ~ThreadedCommandProcessor();
58 59
59 // This takes the ownership of the command 60 // This takes the ownership of the command
60 void Post(ICommand* command); 61 void Post(ICommand* command);
61 62
62 void Join(); 63 bool Join();
63 }; 64 };
64 } 65 }