apache_beam.utils.thread_pool_executor.
UnboundedThreadPoolExecutor
Bases: concurrent.futures._base.Executor
concurrent.futures._base.Executor
submit
Attempts to submit the work item.
A runtime error is raised if the pool has been shutdown.
shutdown
shared_unbounded_instance