7 #include "wvsubprocqueuestream.h" 10 WvSubProcQueueStream::WvSubProcQueueStream(
int _maxrunning)
17 WvSubProcQueueStream::~WvSubProcQueueStream()
26 if (started || run || remain)
27 log(
"Started %s processes (%s running, %s waiting)\n",
28 started, run, remain - run);
unsigned running() const
Return the number of currently running processes.
unsigned remaining() const
Return the number of unfinished (ie. running or waiting) processes.
virtual void execute()
The callback() function calls execute(), and then calls the user- specified callback if one is define...
int go()
Clean up after any running processes in the queue, and start running additional processes if any are ...
A WvLog stream accepts log messages from applications and forwards them to all registered WvLogRcv's...
An ordered queue of WvSubProc instances.