summaryrefslogtreecommitdiff
path: root/src/dispatcher.hpp
diff options
context:
space:
mode:
authorMartin Sustrik <sustrik@250bpm.com>2010-05-05 13:03:26 +0200
committerMartin Sustrik <sustrik@250bpm.com>2010-05-05 13:03:26 +0200
commit44dd005ff05431b05a8e04858a23784b252da870 (patch)
tree0ec8c284057428f2cfa9648cc373a44451cd6dff /src/dispatcher.hpp
parent235ed3a3dcffb7c658cbc9253eae9de54db24533 (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.hpp15
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