relevanceai.concurrency

Multithreading Module

Module Contents

Functions

chunk(iterables, n=20)
multithread(func, iterables, max_workers=8, chunksize=20, show_progress_bar: bool = False)
multiprocess(func, iterables, max_workers=8, chunksize=20, post_func_hook: Callable = None, show_progress_bar: bool = False)

relevanceai.concurrency.chunk(iterables, n=20)

relevanceai.concurrency.multithread(func, iterables, max_workers=8, chunksize=20, show_progress_bar: bool = False)

relevanceai.concurrency.multiprocess(func, iterables, max_workers=8, chunksize=20, post_func_hook: Callable = None, show_progress_bar: bool = False)