  
  from rally.cli import cliutils
 diff --git a/rally/plugins/task/runners/constant.py b/rally/plugins/task/runners/constant.py
-index 5feb1fee1..e872b768b 100644
+index 5feb1fee1..2f6142cfa 100644
 --- a/rally/plugins/task/runners/constant.py
 +++ b/rally/plugins/task/runners/constant.py
+@@ -15,7 +15,7 @@
+ 
+ import collections
+ import multiprocessing
+-import queue as Queue
++import queue
+ import threading
+ import time
+ 
 @@ -24,6 +24,10 @@ from rally.common import validation
  from rally import consts
  from rally.task import runner

Signed-off-by: Cédric Ollivier <cedric.ollivier@orange.com>
---
 rally/cli/main.py                             |  6 +++
 rally/plugins/task/runners/constant.py        | 38 ++++++++++++++++---
 rally/plugins/task/runners/rps.py             |  4 +-
 .../task/scenarios/requests/http_requests.py  |  9 +++++
 .../plugins/task/scenarios/requests/utils.py  |  9 +++++
 rally/task/runner.py                          | 29 ++++++++++++--
 rally/task/utils.py                           | 15 ++++++++
 7 files changed, 99 insertions(+), 11 deletions(-)

diff --git a/rally/cli/main.py b/rally/cli/main.py
index 235a57113..d931924d8 100644

 
-        result_queue = multiprocessing.Queue()
-        event_queue = multiprocessing.Queue()
+        result_queue = queue.Queue()
+        event_queue = queue.Queue()
 
         def worker_args_gen(concurrency_overhead):
             while True:
diff --git a/rally/plugins/task/runners/rps.py b/rally/plugins/task/runners/rps.py
index 98a706d11..26b55feab 100644
--- a/rally/plugins/task/runners/rps.py
+++ b/rally/plugins/task/runners/rps.py
@@ -15,7 +15,7 @@
 
 import collections
 import multiprocessing
-import queue as Queue
+import queue
 import threading
 import time
 
@@ -69,7 +69,7 @@ def _worker_process(queue, iteration_gen, timeout, times, max_concurrent,
         (sleep * info["processes_counter"]) / info["processes_to_start"])
 
     start = time.time()
-    timeout_queue = Queue.Queue()
+    timeout_queue = queue.Queue()
 
     if timeout:
         collector_thr_by_timeout = threading.Thread(
@@ -260,8 +260,8 @@ class RPSScenarioRunner(runner.ScenarioRunner):
                              concurrency_per_worker=concurrency_per_worker,
                              concurrency_overhead=concurrency_overhead)
 
-        result_queue = multiprocessing.Queue()
-        event_queue = multiprocessing.Queue()
+        result_queue = queue.Queue()
+        event_queue = queue.Queue()
 
         def worker_args_gen(times_overhead, concurrency_overhead):
             """Generate arguments for process worker.
