import threading
from concurrent.futures import ThreadPoolExecutor
import time
from tqdm_multi_thread import TqdmMultiThreadFactory
def demo(factory, position, total):
with factory.create(position, total) as progress:
for _ in range(0, total, 5):
progress.update(5)
time.sleep(0.001 * (position % 5 + 1))
with ThreadPoolExecutor(max_workers=20) as executor:
tasks = range(100)
multi_thread_factory = TqdmMultiThreadFactory()
for i, url in enumerate(tasks, 1):
executor.submit(demo, multi_thread_factory, i, 100)
-
Notifications
You must be signed in to change notification settings - Fork 0
A tqdm multi-thread helper
License
boydfd/tqdm_multi_thread
Folders and files
Name | Name | Last commit message | Last commit date | |
---|---|---|---|---|
Repository files navigation
About
A tqdm multi-thread helper
Resources
License
Stars
Watchers
Forks
Releases
No releases published
Packages 0
No packages published