def closeThreads():
    for thread in threads:
        thread.thr_stop()
    for thread in threads:
        thread.wait()
Parallel version of the bulk helper run in multiple threads at once.
dataset/ETHPy150Open bitxbay/BitXBay/bitmessageqt/simple_thread.py/closeThreads--crossover with--dataset/ETHPy150Open elastic/elasticsearch-py/elasticsearch/helpers/__init__.py/parallel_bulk