Блог

я хочу запустить 6 потоков асинхронно, приостановить их и возобновить синхронно…

он должен работать так:

1. Запуск потока 1 (thr1.start())
2. Поток 1 некоторый прогресс (получение mac-адресов из txt-файла, инициализация com-объектов)
3. Поток 1 приостановлен (приостановлен до тех пор, пока все потоки не выполнят то же самое, что и поток 1)
4. Запуск потока 2
5. Поток 2 некоторый прогресс
6. Поток 2 приостановлен
7. Запуск потока 3
8. Поток 3 некоторый прогресс
9. Поток 3 приостановлен
10. …
11. после того, как все 6 потоков приостановлены, они должны возобновить все..

я попробовал с 6 простыми логическими флагами и подождал, пока все они true не станут совсем грязными…

есть идеи?

РЕДАКТИРОВАТЬ (улучшенная визуализация):

 Thr1 | Initiliazing |waiting      |waiting      | Resuming
Thr2 | waiting      |Initiliazing |waiting      | Resuming
Thr3 | waiting      |waiting      |Initiliazing | Resuming
...           
 

спасибо и приветствую,
flux

Вам нужна какая-то синхронизация — вероятно, звучит ManualResetEvent для каждого потока, в зависимости от функций вашего потока.

РЕДАКТИРОВАТЬ: Спасибо за ваши обновления — вот простой пример:

 // initComplete is set by each worker thread to tell StartThreads to continue
//     with the next thread
//
// allComplete is set by StartThreads to tell the workers that they have all
//     initialized and that they may all resume


void StartThreads()
{
    var initComplete = new AutoResetEvent( false );
    var allComplete = new ManualResetEvent( false );

    var t1 = new Thread( () => ThreadProc( initComplete, allComplete ) );
    t1.Start();
    initComplete.WaitOne();

    var t2 = new Thread( () => ThreadProc( initComplete, allComplete ) );
    t2.Start();
    initComplete.WaitOne();

    // ...

    var t6 = new Thread( () => ThreadProc( initComplete, allComplete ) );
    t6.Start();
    initComplete.WaitOne();

    // allow all threads to continue
    allComplete.Set();
}


void ThreadProc( AutoResetEvent initComplete, WaitHandle allComplete )
{
    // do init

    initComplete.Set(); // signal init is complete on this thread

    allComplete.WaitOne(); // wait for signal that all threads are ready

    // resume all
}
 

Обратите внимание, что StartThreads метод будет блокироваться во время инициализации потоков — это может быть или не быть проблемой.