mirror of
git://git.yoctoproject.org/poky.git
synced 2025-07-19 21:09:03 +02:00
lib/oe/utils: Drop now unused multiprocess_exec
(From OE-Core rev: f3b30def2cd1c9ede7630489c3949a45b6eba6ed) Signed-off-by: Richard Purdie <richard.purdie@linuxfoundation.org>
This commit is contained in:
parent
adea90740d
commit
34c2bd84ee
|
@ -248,40 +248,6 @@ def execute_pre_post_process(d, cmds):
|
|||
bb.note("Executing %s ..." % cmd)
|
||||
bb.build.exec_func(cmd, d)
|
||||
|
||||
def multiprocess_exec(commands, function):
|
||||
import signal
|
||||
import multiprocessing
|
||||
|
||||
if not commands:
|
||||
return []
|
||||
|
||||
def init_worker():
|
||||
signal.signal(signal.SIGINT, signal.SIG_IGN)
|
||||
|
||||
fails = []
|
||||
|
||||
def failures(res):
|
||||
fails.append(res)
|
||||
|
||||
nproc = min(multiprocessing.cpu_count(), len(commands))
|
||||
pool = bb.utils.multiprocessingpool(nproc, init_worker)
|
||||
|
||||
try:
|
||||
mapresult = pool.map_async(function, commands, error_callback=failures)
|
||||
|
||||
pool.close()
|
||||
pool.join()
|
||||
results = mapresult.get()
|
||||
except KeyboardInterrupt:
|
||||
pool.terminate()
|
||||
pool.join()
|
||||
raise
|
||||
|
||||
if fails:
|
||||
raise fails[0]
|
||||
|
||||
return results
|
||||
|
||||
# For each item in items, call the function 'target' with item as the first
|
||||
# argument, extraargs as the other arguments and handle any exceptions in the
|
||||
# parent thread
|
||||
|
|
Loading…
Reference in New Issue
Block a user