我需要通过外部程序处理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/

10-09 13:21