pyspeedup/concurrent/_cache.py
def _batchAsync(a_dict,a_queue,func,*items):
    '''This smartly decides how to branch asynchronously and does so synchronously if only one item is missing.'''
    items = [item for item in items if item not in a_dict]
    if len(items)>1:
        for item in items:
            a_dict[item]=_StillWaiting
            a_queue.put(item)
This smartly decides how to branch asynchronously and does so synchronously if only one item is missing.
This smartly decides how to branch asynchronously and does so synchronously if only one item is missing.
This smartly decides how to branch asynchronously and does so synchronously if only one item is missing .
def _batchAsync(a_dict,a_queue,func,*items):
    items = [item for item in items if item not in a_dict]
    if len(items)>1:
        for item in items:
            a_dict[item]=_StillWaiting
            a_queue.put(item)
def _batchAsync ( a_dict , a_queue , func , * items ) : items = [ item for item in items if item not in a_dict ] if len ( items ) > 1 : for item in items : a_dict [ item ] = _StillWaiting a_queue . put ( item )
This smartly decides how to branch asynchronously and does so synchronously if only one item is missing.
This smartly decides how to branch asynchronously and does so synchronously if only one item is missing .
'''This smartly decides how to branch asynchronously and does so synchronously if only one item is missing.'''
a_dict
a_queue
func