docs: Fix warning treated as error
Change-Id: I669533334419e94ca925e859f2b0d5d2afe9f7f1
This commit is contained in:
@@ -168,6 +168,12 @@ class ConnectionThreadPoolExecutor(ThreadPoolExecutor):
|
|||||||
We will only create as many connections as are required concurrently.
|
We will only create as many connections as are required concurrently.
|
||||||
"""
|
"""
|
||||||
def __init__(self, create_connection, max_workers):
|
def __init__(self, create_connection, max_workers):
|
||||||
|
"""
|
||||||
|
Initializes a new ThreadPoolExecutor instance.
|
||||||
|
|
||||||
|
:param create_connection: callable to use to create new connections
|
||||||
|
:param max_workers: the maximum number of threads that can be used
|
||||||
|
"""
|
||||||
self._connections = PriorityQueue()
|
self._connections = PriorityQueue()
|
||||||
self._create_connection = create_connection
|
self._create_connection = create_connection
|
||||||
for p in range(0, max_workers):
|
for p in range(0, max_workers):
|
||||||
|
Reference in New Issue
Block a user