【发布时间】:2020-11-09 08:51:15
【问题描述】:
if math.fabs(time.time()-start_time) > time_interval :
TypeError: '>' 在 'float' 和 'Synchronized' 的实例之间不支持
代码:
if __name__ == "__main__":
start_time = multiprocessing.Value( 'd', 0.0)
time_t = multiprocessing.Value('d', 0.005)
producer(all_client, q[0], time_t, start_time, t)
...
def producer(sequence, output_q, time_interval, start_time, t):
start_time = t = time.time()
for item in sequence:
time.sleep(random.expovariate(glamda[0]))
item.time_arrived = item.V_entered[0]= time.time()
output_q.put(item)
if math.fabs(time.time()-start_time) > time_interval :
print("producer time out ", time_t)
break
【问题讨论】:
标签: python-3.x synchronized consumer producer multiqueue