pyspeedup/concurrent/_cache.py
def _parallelRun(a_queue,a_dict,a_func_marshal,a_func_name,a_task, an_event):
    '''This runs a function, piping recursive calls to the _taskManager through a provided Queue.'''
    try:
        a_func=FunctionType(loads(a_func_marshal),globals(),"a_func")
        globals()[a_func_name]=partial(_getValue,a_dict,a_queue,an_event,True,a_func)
        globals()[a_func_name].apply_async=partial(_getValue,a_dict,a_queue,an_event,False,a_func)
        globals()[a_func_name].batch_async=partial(_batchAsync,a_dict,a_queue,a_func)
        #setattr(globals()[a_func_name],"__contains__",a_dict.__contains__)
        a_result=a_func(*a_task)
        a_dict[a_task]=a_result
        an_event.set()
        an_event.clear()
    except:
        traceback.print_exc()
        a_dict[a_task]=None
        an_event.clear()
This runs a function, piping recursive calls to the _taskManager through a provided Queue.
This runs a function, piping recursive calls to the _taskManager through a provided Queue.
This runs a function piping recursive calls to the _taskManager through a provided Queue .
def _parallelRun(a_queue,a_dict,a_func_marshal,a_func_name,a_task, an_event):
    try:
        a_func=FunctionType(loads(a_func_marshal),globals(),"a_func")
        globals()[a_func_name]=partial(_getValue,a_dict,a_queue,an_event,True,a_func)
        globals()[a_func_name].apply_async=partial(_getValue,a_dict,a_queue,an_event,False,a_func)
        globals()[a_func_name].batch_async=partial(_batchAsync,a_dict,a_queue,a_func)
        a_result=a_func(*a_task)
        a_dict[a_task]=a_result
        an_event.set()
        an_event.clear()
    except:
        traceback.print_exc()
        a_dict[a_task]=None
        an_event.clear()
def _parallelRun ( a_queue , a_dict , a_func_marshal , a_func_name , a_task , an_event ) : try : a_func = FunctionType ( loads ( a_func_marshal ) , globals ( ) , "a_func" ) globals ( ) [ a_func_name ] = partial ( _getValue , a_dict , a_queue , an_event , True , a_func ) globals ( ) [ a_func_name ] . apply_async = partial ( _getValue , a_dict , a_queue , an_event , False , a_func ) globals ( ) [ a_func_name ] . batch_async = partial ( _batchAsync , a_dict , a_queue , a_func ) a_result = a_func ( * a_task ) a_dict [ a_task ] = a_result an_event . set ( ) an_event . clear ( ) except : traceback . print_exc ( ) a_dict [ a_task ] = None an_event . clear ( )
This runs a function, piping recursive calls to the _taskManager through a provided Queue.
This runs a function piping recursive calls to the _taskManager through a provided Queue .
'''This runs a function, piping recursive calls to the _taskManager through a provided Queue.''' #setattr(globals()[a_func_name],"__contains__",a_dict.__contains__)
a_queue
a_dict
a_func_marshal
a_func_name
a_task
an_event