Блог

При одновременном запуске двух задач (или почти одновременно) с задачей.Factory.StartNew(), одна из них всегда завершается немедленно.

У меня есть функция, которая создает задачу из основного потока, которая затем сама запускает некоторое количество задач в зависимости от количества параллельных заданий, которые необходимо выполнить. Более конкретно, у меня есть приложение, которое удаленно выполняет сканирование на «x» количестве компьютеров, и каждое задание сканирования может содержать «y» количество определений отдельных заданий сканирования, которые необходимо запускать одно за другим. Фактическое сканирование выполняется отдельным EXE-файлом командной строки. При попытке запуска на двух компьютерах первое сканирование первого компьютера на долю секунды открывает окно командной строки, а затем немедленно закрывается, в то время как остальная часть процесса продолжается по назначению. Я перепробовал много вариантов одного и того же кода, и единственным надежным решением является создание потока.Sleep() внутри цикла foreach, что позволяет ему работать просто отлично.

Выполняемый код выглядит примерно так:

 private void StartClicked(object sender, MouseButtonEventArgs e)
{
    // Gather information about the job here

    Task.Factory.StartNew(() => RunJobs(listOfJobs), TaskCreationOptions.LongRunning)

    // Do some other stuff while tasks run.
}

private void RunJobs(Queue<Job> p_jobs)
{
    while (p_jobs.Any())
    {
        var job = p_jobs.Dequeue();
        Task.Factory.StartNew(() => BeginScan(job), TaskCreationOptions.LongRunning);
        // Adding Thread.Sleep(someNumber) here fixes the issue, but I don't want to rely on that.
    }
}

private void BeginScan(Job p_job)
{
    foreach(var scanPolicy in p_job.PoliciesForExecution)
    {
        PolicyScan(scanPolicy);
    }
}

private void PolicyScan(Policy p_policy)
{
    // Launch exe with some parameters here.
}
  

Что здесь не так? Почему добавление ручного потока.Sleep() устраняет проблему?