Add a results queue

1 files changed, 2 insertions, 0 deletions

diff --git a/flake8/checker.py b/flake8/checker.py
index 0398187..274dc23 100644
--- a/flake8/checker.py
+++ b/flake8/checker.py
@@ -55,6 +55,7 @@ class Manager(object):
         self.checks = checker_plugins
         self.jobs = self._job_count()
         self.process_queue = None
+        self.results_queue = None
         self.using_multiprocessing = False
         self.processes = []
         self.checkers = []
@@ -62,6 +63,7 @@ class Manager(object):
         if self.jobs is not None and self.jobs > 1:
             self.using_multiprocessing = True
             self.process_queue = multiprocessing.Queue()
+            self.results_queue = multiprocessing.Queue()
 
     def _job_count(self):
         # type: () -> Union[int, NoneType]