Блог

У меня есть консольное приложение на c #, которое создает до 5 потоков.

Потоки выполняются нормально, но поток пользовательского интерфейса завершает свою работу.

Есть ли способ поддерживать работу основного потока пользовательского интерфейса до тех пор, пока выполняются побочные потоки?

 foreach (var url in urls)
{
    Console.WriteLine("starting thread: "   url); 
    ThreadPool.QueueUserWorkItem(new System.Threading.WaitCallback(myMethod), url);
}
  

Я запускаю свои потоки в соответствии с приведенным выше кодом.

Потоки в пуле потоков являются фоновыми потоками, и это означает, что завершающее приложение не будет ждать их завершения.

У вас есть несколько вариантов:

• подождите, например, с семафором
• подождите на счетчике с помощью функции Sleep() , очень грубо, но подходит для простого консольного приложения.
• используйте TPL, Parallel.ForEach(urls, url => MyMethod(url));

Если вы используете .NET 4.0:

 var tasks = new List<Task>();

foreach(var url in urls)
{
    tasks.Add(Task.Factory.StartNew(myMethod, url));
}

// do other stuff...

// On shutdown, give yourself X number of seconds to wait for them to complete...
Task.WaitAll(tasks.ToArray(), TimeSpan.FromSeconds(30));
  

Ах — пул потоков является фоновым. Оно ставится в очередь, но затем ваша программа завершается. ЗАКОНЧЕННЫЕ. Программа завершается.

Прочитайте семафоры (WaitSignal) и подождите — потоки в обратном вызове в конце сигнализируют о завершении, когда все сигнализируют, что основной поток может продолжаться.

Если вы используете .net 4, то:

 urls.AsParallel().ForAll(MyMethod);
  

До .net 4 затем запускайте отдельные потоки, сохраняйте их в списке и вызывайте Join() . Тот факт, что рабочие элементы не являются фоновыми, сохранит их работоспособность после завершения основного потока, но Join() является более явным.

         List<Thread> workers = new List<Thread>();
        foreach(var url in urls)
        {
            Thread t = new Thread(MyMethod) {IsBackground = false};
            workers.Add(t);
            t.Start(url);
        }

        foreach (var worker in workers)
        {
            worker.Join();
        }
  

Самый простой способ исправить вашу проблему.

В вашем классе program:

 static volatile int ThreadsComplete = 0;
  

В вашем «myMethod» в конце перед возвратом:

 //ThreadsComplete  ; //*edit* for safety's sake
Interlocked.Increment(ref ThreadsComplete);
  

В вашем основном методе, прежде чем он вернется / завершится:

 while(ThreadsComplete < urls.Count) { Thread.Sleep(10); }
  

Приведенное выше по существу объединяет метод синхронизации WaitForAll.

в основном:

 var m = new ManualResetEvent(false);
// do something
foreach (var url in urls)
{
  Console.WriteLine("starting thread: "   url); 
  ThreadPool.QueueUserWorkItem(new System.Threading.WaitCallback(myMethod), url);
}
m.WaitOne();


private static void myMethod(object obj)
{
  try{
   // do smt
  }
  finally {
    m.Set();
  }
}