diff options
author | Martin Sustrik <sustrik@250bpm.com> | 2010-05-05 13:03:26 +0200 |
---|---|---|
committer | Martin Sustrik <sustrik@250bpm.com> | 2010-05-05 13:03:26 +0200 |
commit | 44dd005ff05431b05a8e04858a23784b252da870 (patch) | |
tree | 0ec8c284057428f2cfa9648cc373a44451cd6dff /src/dispatcher.hpp | |
parent | 235ed3a3dcffb7c658cbc9253eae9de54db24533 (diff) |
number of application threads to use 0MQ sockets is unlimited; app_threads parameter in zmq_init is unused and obsolete
Diffstat (limited to 'src/dispatcher.hpp')
-rw-r--r-- | src/dispatcher.hpp | 15 |
1 files changed, 3 insertions, 12 deletions
diff --git a/src/dispatcher.hpp b/src/dispatcher.hpp index 0986e8a..cad4844 100644 --- a/src/dispatcher.hpp +++ b/src/dispatcher.hpp @@ -34,23 +34,14 @@ namespace zmq { - - // Dispatcher implements bidirectional thread-safe passing of commands - // between N threads. It consists of a ypipes to pass commands and - // signalers to wake up the receiver thread when new commands are - // available. Note that dispatcher is inefficient for passing messages - // within a thread (sender thread = receiver thread). The optimisation is - // not part of the class and should be implemented by individual threads - // (presumably by calling the command handling function directly). class dispatcher_t { public: - // Create the dispatcher object. Matrix of pipes to communicate between - // each socket and each I/O thread is created along with appropriate - // signalers. - dispatcher_t (uint32_t app_threads_, uint32_t io_threads_); + // Create the dispatcher object. The argument specifies the size + // of I/O thread pool to create. + dispatcher_t (uint32_t io_threads_); // This function is called when user invokes zmq_term. If there are // no more sockets open it'll cause all the infrastructure to be shut |