--- mga-gnome/trunk/mga-gnome	2013/05/25 09:56:33	8388
+++ mga-gnome/trunk/mga-gnome	2013/05/25 14:48:34	8389
@@ -52,6 +52,8 @@
 # check-latest
 import requests
 
+import multiprocessing
+
 SLEEP_INITIAL=180
 SLEEP_REPEAT=30
 SLEEP_TIMES=30
@@ -674,13 +676,18 @@
         fdst.flush()
         os.rename(fdst.name, path)
 
+def cmd_co_multi(l):
+    package, module, package_version, spec_version, downstream_files = l
+
+    print "%s => %s" % (module, package)
+    try:
+        Downstream.co(package)
+    except subprocess.CalledProcessError:
+        pass
+
 def cmd_co(options, parser):
-    for package, module, package_version, spec_version, downstream_files in sorted(join_streams()):
-        print "%s => %s" % (module, package)
-        try:
-            Downstream.co(package)
-        except subprocess.CalledProcessError:
-            pass
+    p = multiprocessing.Pool(5)
+    p.map(cmd_co_multi, sorted(join_streams()))
 
 def join_streams(show_version=False, only_diff_version=False):
     root = os.path.expanduser(Downstream.PKGROOT)