parallel_change_blob_access_tier.py [286:294]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    q = Queue(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 thread {}'.format(i))
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



parallel_delete_blobs.py [216:224]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
    q = Queue(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 thread {}'.format(i))
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -