linspector/linspector-old
2
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

just playing around with a process pool. do not use this commits code!

Browse source
This commit is contained in:
Johannes Findeisen 2013-12-07 18:59:36 +01:00
commit 2ae5b8bd2f
1 changed files with 7 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

8
bin/linspector
View file

@ -29,6 +29,8 @@ import logging.handlers
import os import os
import os.path as path import os.path as path
import sys import sys
import multiprocessing
from multiprocessing import Pool
from linspector.config.parser import FullConfigParser from linspector.config.parser import FullConfigParser
from linspector.core.interface import LinspectorInterface from linspector.core.interface import LinspectorInterface
@ -89,8 +91,12 @@ def parse_args():
return parser.parse_args() return parser.parse_args()
pool = Pool(processes=16)
print 'cpu_count() = %d\n' % multiprocessing.cpu_count()
def handle_job(job): def handle_job(job):
job.handle_call() result = pool.apply_async(job.handle_call())
def main(): def main():