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 ...
void alarm(time_t msec_timeout)
set an alarm, ie.
A WvLog stream accepts log messages from applications and forwards them to all registered WvLogRcv's...
An ordered queue of WvSubProc instances.