回答此问题可获得 20 贡献值,回答如果被采纳可获得 50 分。
<pre><code>#!/usr/bin/env python
import multiprocessing
def tempx((the_time)):
return int(the_time)*int(the_time)
def tempy((the_time, foobar)):
return int(the_time)/(float(foobar))+100
def mp_handler():
p = multiprocessing.Pool(2)
foo = p.map(tempx, [('2')])
print foo
foo = p.map(tempy, [('100', '100000')])
print foo
if __name__ == '__main__':
mp_handler()
</code></pre>
<p>我有两个输入参数不同的方法。第一个方法只有:<code>the_time</code>,第二个方法只有<code>the_time and foobar</code></p>
<p>我需要按特定顺序显示结果,因此我使用了map函数。但是,据我所知,上面的代码根本没有使用多进程模块,因为我使用的是两个<code>map</code>函数。我说得对吗?你知道吗</p>
<p>最终目标是同时运行两个方法。你知道吗</p>
<p>我错过了什么?你知道吗</p>
<p>达诺,这是我正在做的一件事</p>
<pre><code> import multiprocessing
def print_timing(func):
def wrapper(*arg):
t1 = time.time()
res = func(*arg)
t2 = time.time()
print '%s took %0.3f ms' % (func.func_name, (t2-t1)*1000.0)
return res
return wrapper
@print_timing
def case_one(power_pred, power_core, num_thrs, possible_frequency, clamp_range):
ds1_cur_freq = list()
ds1_freq_index = list()
ds1_cur_clamp = list()
return ds1_cur_freq, ds1_freq_index, ds1_cur_clamp
@print_timing
def case_two(cpower_pred, power_core, num_thrs, possible_frequency, TT_index, DT_index, clamp_range):
ds2_cur_freq = list()
ds2_freq_index = list()
ds2_cur_clamp = list()
return ds2_cur_freq, ds2_freq_index, ds2_cur_clamp
def defs_finder():
cpower_pred = list()
power_pred = list()
power_core = list()
num_thrs = 3
possible_frequency = list()
clamp_range= list()
DT_index =1
TT_index = 0
p = multiprocessing.Pool(2)
#Case 1: DS1
# ds1_cur_freq, ds1_freq_index, ds1_cur_clamp =
ds1 = p.apply_async(case_one, args=(power_pred, power_core, num_thrs, possible_frequency))
#Case 1: DS1
# ds1_cur_freq, ds1_freq_index, ds1_cur_clamp = case_one(power_pred, power_core, num_thrs, possible_frequency, clamp_range)
#Case 2: DS2
# ds2_cur_freq, ds2_freq_index, ds2_cur_clamp = case_two(cpower_pred, power_core, num_thrs, possible_frequency, TT_index, DT_index, clamp_range)
ds2 = p.apply_async(case_two, args=(cpower_pred, power_core, num_thrs, possible_frequency, TT_index, DT_index))
print ds1
print ds2
print ds1.get()
print ds2.get()
# ds1_cur_freq = ds1.get()[0]
# ds1_freq_index = ds1.get()[1]
# ds1_cur_clamp = ds1.get()[2]
# ds2_cur_freq = ds2.get()[0]
# ds2_freq_index = ds2.get()[1]
# ds2_cur_clamp = ds2.get()[2]
defs_finder()
</code></pre>
<p>这就是它现在是如何实现的,这个bug是如何重现的</p>