traffic_assignment_procedure.py 文件源码

python
阅读 21 收藏 0 点赞 0 评论 0

项目:AequilibraE 作者: AequilibraE 项目源码 文件源码
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)
评论列表
文章目录


问题


面经


文章

微信
公众号

扫码关注公众号