From: Yigong Liu (yigongliu_at_[hidden])
Date: 2006-09-25 03:26:11
Is there stilll any interests in a template library for distributed message
passing and event dispatching? I finally got time to redesign and
reimplement the library (Channel) based on Boost. Initial design document
and code is available from sourceforge:
I have done most of my coding and testing in linux (Fedora Core 3 &4).
Havent try it on Windows yet. I'd like to hear from the community on the
FYI, the following is a introduction of the library.
In Unix and most OSes, file systems allow applications to identify, bind to
and operate on system resources and entities (devices, files,...) using a
"name" (path name) in a hierarchical namespace (directory system) which is
different from variables and pointers in flat address space.
In Boost.Signal and libsigc++, callbacks/slots objects can be connected
explicitly to specific signals objects to allow synchronous event
Channel is a C++ template library to provide namespaces for asynchronous,
distributed message passing and event dispatching. Message senders and
receivers bind to names in namespace; binding and matching rules decide
which senders will bind to which receivers; then message passing and event
dispatching could happen among bound senders and receivers.
typename platform_type = boost_platform,
typename synchpolicy = mt_synch<platform_type>,
typename executor_type = abstract_executor,
typename name_space =
typename dispatcher = broadcast_dispatcher<name_space,platform_type>
Various namespaces (linear/hierarchical/associative) can be used for
different applications. For example, we can use integer ids as names to send
messages in linear namespace or we can use path name ids to send messages in
hierarchical namespace; User can configure namespace easily by setting a
channel template parameter.
Channel's other major components are dispatchers; which dispatch
messages/events from senders to bounded receivers. Dispatcher is also a
channel template parameter. The design of dispatchers can vary in several
- how msgs move: push or pull;
- how callbacks executed: synchronous or asynchronous.
Sample dispatchers includes : synchronous broadcast dispatcher, buffered
Namespace and dispatchers are orthogonal; they can mix and match together
freely; just as STL algorithms can be used with any STL containers by means
of the iterator range concept, Namespace and dispatchers can be used
together because of the name binding set concept.
By combining different namespace and dispatching policies, we can achieve
- synchronous event dispatching
- associative space model similar to tuple space
- asynchronous messaging model similar to Microsoft CCR (Concurrency
Similar to distributed files systems, distributed channels can be connected
or "mounted" to allow transparent distributed message passing. Filters and
translators are used to control namespace changes.
Channel is built on top of Boost facilities:
- boost::shared_ptr for message/event data life-time management
- boost::bind, boost::function for callback
- boost::thread for synchronization
- boost::serialization for message marshaling/demarshaling
- Boost.Asio and Boost.Shmem are used to build transports among remote
Boost list run by bdawes at acm.org, gregod at cs.rpi.edu, cpdaniel at pacbell.net, john at johnmaddock.co.uk