#NEWLINE# def _spawn_producer( f , port , addr = 'tcp://127.0.0.1' ) : #NEWLINE# #INDENT# 'Start a process that sends results on a PUSH socket.\n\n    Parameters\n    ----------\n    f : callable\n        Callable that takes a single argument, a handle\n        for a ZeroMQ PUSH socket. Must be picklable.\n\n    Returns\n    -------\n    process : multiprocessing.Process\n        The process handle of the created producer process.\n\n    ' #NEWLINE# process = Process ( target = _producer_wrapper , args = ( f , port , process ) ) #NEWLINE# process . start ( ) #NEWLINE# return process