          if times is not None:
              return iteration < times and not aborted.is_set()
          elif duration is not None:
+@@ -74,7 +81,7 @@ def _worker_process(queue, iteration_gen, timeout, concurrency, times,
+                             method_name=method_name, args=args)
+ 
+     if timeout:
+-        timeout_queue = Queue.Queue()
++        timeout_queue = queue.Queue()
+         collector_thr_by_timeout = threading.Thread(
+             target=utils.timeout_thread,
+             args=(timeout_queue, )
 @@ -82,6 +89,7 @@ def _worker_process(queue, iteration_gen, timeout, concurrency, times,
          collector_thr_by_timeout.start()
  

From 41256d0983cda2914948898c5d4a0f74fa161dac Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?C=C3=A9dric=20Ollivier?= <cedric.ollivier@orange.com>
Date: Thu, 30 Apr 2020 13:59:24 +0200
Subject: [PATCH] Try to detect the race conditions

 
-        result_queue = multiprocessing.Queue()
-        event_queue = multiprocessing.Queue()
+        result_queue = queue.Queue()
+        event_queue = queue.Queue()
 
         def worker_args_gen(concurrency_overhead):
             while True:
