diff --git a/lib/ansible/runner/__init__.py b/lib/ansible/runner/__init__.py
index e92f27fe562..ab2acd167f5 100644
--- a/lib/ansible/runner/__init__.py
+++ b/lib/ansible/runner/__init__.py
@@ -565,7 +565,6 @@ class Runner(object):
         p = multiprocessing.Pool(self.forks)
         try:
             result = p.map(_executor_hook, hosts)
-            p.close()
         except KeyboardInterrupt:
             p.terminate()
             raise errors.AnsibleError("Interrupted")