parallel_change_blob_access_tier.py [313:321]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    q = multiprocessing.JoinableQueue(max_queue_size)
    
    producer = Thread(target=producer_func,args=(q,input_file,))
    producer.daemon = False
    producer.start()
    
    for i in range(n_threads):
        if verbose:
            print('Starting process {}'.format(i))
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



parallel_delete_blobs.py [241:249]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    q = multiprocessing.JoinableQueue(max_queue_size)
    
    producer = Thread(target=producer_func,args=(q,input_file,))
    producer.daemon = False
    producer.start()
    
    for i in range(n_threads):
        if verbose:
            print('Starting process {}'.format(i))
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -