def doWork(self):
self.emit(SIGNAL("ProgressMaxValue(PyQt_PyObject)"), self.matrix.shape[0])
self.emit(SIGNAL("ProgressValue(PyQt_PyObject)"), 0)
# If we are going to perform All or Nothing
if self.method['algorithm'] == 'AoN':
pool = ThreadPool(self.results.cores)
self.all_threads['count'] = 0
for O in range(self.results.zones):
a = self.matrix[O, :]
if np.sum(a) > 0:
pool.apply_async(self.func_assig_thread, args=(O, a))
pool.close()
pool.join()
self.emit(SIGNAL("ProgressValue(PyQt_PyObject)"), self.matrix.shape[0])
self.results.link_loads = np.sum(self.aux_res.temp_link_loads, axis=1)
self.emit(SIGNAL("ProgressText (PyQt_PyObject)"), "Saving Outputs")
self.emit(SIGNAL("finished_threaded_procedure( PyQt_PyObject )"), None)
traffic_assignment_procedure.py 文件源码
python
阅读 21
收藏 0
点赞 0
评论 0
评论列表
文章目录