我需要通过外部程序处理100条信息。这些过程可能非常耗时,因此我需要将其限制为一次只能处理8个。本质上,我想启动8个流程,并在每个流程完成后启动下一个流程。
我试图在System.Threading.Tasks.Dataflow中将TPL与以下代码一起使用,但要全部100次启动,而不是一次仅启动8次。
// This file has the command line parameters to launch the external process
List<string> lines = File.ReadAllLines(file).ToList();
var block = new ActionBlock<string>(async job => await RunJob(job), new ExecutionDataflowBlockOptions { MaxDegreeOfParallelism = 1 });
foreach (string line in lines)
{
block.SendAsync(line);
}
static async Task RunJob(string parms)
{
//Console.WriteLine("PARMS: {0}", parms);
Process proc = new Process();
ProcessStartInfo start = new ProcessStartInfo();
start.WindowStyle = ProcessWindowStyle.Normal;
start.FileName = @"C:\program.exe";
string parameters = String.Format(parms.ToString());
start.Arguments = parameters;
start.UseShellExecute = true;
proc.StartInfo = start;
proc.Start();
}
我错过了什么?谢谢您的帮助。
最佳答案
流程立即开始,但是您不必等到流程结束。使用proc.WaitForExit();
static async Task RunJob(string parms)
{
//Console.WriteLine("PARMS: {0}", parms);
Process proc = new Process();
ProcessStartInfo start = new ProcessStartInfo();
start.WindowStyle = ProcessWindowStyle.Normal;
start.FileName = @"C:\program.exe";
string parameters = String.Format(parms.ToString());
start.Arguments = parameters;
start.UseShellExecute = true;
proc.StartInfo = start;
proc.Start();
proc.WaitForExit();
}
关于c# - 执行队列,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/52436123/