multiprocessing.Pool

python/sepolicy/sepolicy.py

@@ -25,7 +25,7 @@
 import sys
 import selinux
 import sepolicy
-from concurrent.futures import ProcessPoolExecutor
+from multiprocessing import Pool
 from sepolicy import get_os_version, get_conditionals, get_conditionals_format_text
 import argparse
 PROGNAME = "policycoreutils"
@@ -346,9 +346,11 @@ def manpage(args):
     else:
         test_domains = args.domain
 
-    with ProcessPoolExecutor() as e:
-        for domain in test_domains:
-            e.submit(manpage_work, domain, path, args.root, args.source_files, args.web)
+    p = Pool()
+    for domain in test_domains:
+        p.apply_async(manpage_work, [domain, path, args.root, args.source_files, args.web])
+    p.close()
+    p.join()
 
     if args.web:
         HTMLManPages(manpage_roles, manpage_domains, path, args.os)