environment/share/doc/ipython/examples/parallel/interengine/interengine.py
def send(client, sender, targets, msg_name, dest_name=None, block=None):
    """send a message from one to one-or-more engines."""
    dest_name = msg_name if dest_name is None else dest_name
    def _send(targets, m_name):
        msg = globals()[m_name]
        return com.send(targets, msg)
        
    client[sender].apply_async(_send, targets, msg_name)
    
    return client[targets].execute('%s=com.recv()'%dest_name, block=None)
def send(client, sender, targets, msg_name, dest_name=None, block=None):
    dest_name = msg_name if dest_name is None else dest_name
    def _send(targets, m_name):
        msg = globals()[m_name]
        return com.send(targets, msg)
        
    client[sender].apply_async(_send, targets, msg_name)
    
    return client[targets].execute('%s=com.recv()'%dest_name, block=None)
def send ( client , sender , targets , msg_name , dest_name = None , block = None ) : dest_name = msg_name if dest_name is None else dest_name def _send ( targets , m_name ) : msg = globals ( ) [ m_name ] return com . send ( targets , msg ) client [ sender ] . apply_async ( _send , targets , msg_name ) return client [ targets ] . execute ( '%s=com.recv()' % dest_name , block = None )
send a message from one to one-or-more engines.
send a message from one to one - or - more engines .