我目前正在我的大学与交通灯进行一个项目。我使用SUMO作为我的模拟程序,我偶然发现了用于控制交通灯的TraCI库。
我已经编写了一个遗传算法,但我有一个问题,实质上是一个瓶子,这么小,没有粒子可以通过,这就是模拟程序本身。
当从同一个程序(我的程序)控制多个客户端时,所有客户端都运行在2个线程上,在我的情况下我有8个可用。我在多线程中运行程序的意图是程序将运行得更快,因为即使我只模拟了大约40分钟的流量,100次模拟也需要大约1.5小时才能完成。
我在下面发布了初始化,启动客户端并控制它们的方法。
主要罪魁祸首可能是最后一个for-loop中的两个方法调用(控制交通信号灯的方法)
所以我的问题是,如何在多线程上运行并行化,所以程序运行得更快?
最好的祝福
private async Task RunSimulationAsync()
{
List<TraCIClient> listOfClients = new List<TraCIClient>();
List<SimulationCommands> listOfSimulations = new List<SimulationCommands>();
List<TrafficLightCommands> listOfTrafficLights = new List<TrafficLightCommands>();
//initialize clients, simulationCommands and trafficlightCommands used for controlling sumo
for (int i = 0; i < numberOfInstances; ++i)
{
listOfClients.Add(new TraCIClient());
listOfSimulations.Add(new SimulationCommands(listOfClients[i]));
listOfTrafficLights.Add(new TrafficLightCommands(listOfClients[i]));
}
//open SUMO clients
for (int i = 0; i < numberOfInstances; ++i)
{
OpenSumo(portNumber, sumoOutputFilePath + $"{i}.xml");
await listOfClients[i].ConnectAsync("127.0.0.1", portNumber);
++portNumber;
}
// control trafficlights in simulation
for (int i = 0; i < dnaSize; ++i)
{
for (int j = 0; j < numberOfInstances; j++)
{
listOfTrafficLights[j].SetRedYellowGreenState("n0", $" {Population[j].genes[i]}");
listOfClients[j].Control.SimStep();
}
}
如何将其并行化以在多个线程上运行,以便程序运行得更快?
首先,您需要确保您正在使用的库能够以并行方式调用。并非所有人都是。
第二,既然你有一个for
索引,那么最直接的翻译就是使用Parallel.For
,例如:
for (int i = 0; i < dnaSize; ++i)
{
Parallel.For(0, numberOfInstances, j =>
{
listOfTrafficLights[j].SetRedYellowGreenState("n0", $" {Population[j].genes[i]}");
listOfClients[j].Control.SimStep();
}
}
这将并行化为实例数。