ActiveObject.cpp

См. документацию.

/*
 * CntmLib - Подсчет ссылок, потоки, синхронизация, асинхронные процедуры, события
 * Copyright (c) 2005, Овсеевич Роман, CntmLib@mail.ru
 * _______________________________________________________________________________
 * Разрешено свободное использование, копирование, распространение, изменение
 * (изменение сведений об авторских правах запрещено). Запрещена продажа и 
 * включение всей библиотеки или ее частей в другие библиотеки. В сведениях об
 * авторских правах на программу (или сведениях о программе, об авторах, 
 * использованных средствах разработки и т.д.) должна быть указана информация
 * о библиотеке CntmLib, ее авторе и, возможно, сайте или email'е.
 * Библиотека поставляется "как есть", без каких-либо гарантий со стороны автора.
 */ 

#include <Cntm/ActiveObjects/ActiveObject.h>

void Cntm::ActiveObject::TerminateAllThreads()
{
        // Сообщаем всем потокам о завершении.
        ThreadsRegister::Enumerator en = threadsRegister.GetEnumerator();
        while (en.Next()) en.Current()->Terminate(); 

        // Проверяем, все ли потоки завершены, если все, то вызываем AllThreadsFinished().
        CheckAllThreadsFinished();
}

void Cntm::ActiveObject::CheckAllThreadsFinished()
{
        if (threadsCount.DecAndTest())
        { // Только когда потоков не осталось и TerminateAllThreads() закончил работу.
                threadsCount.Inc(); // Возвращаем начальное значение 1.
                AllThreadsFinished(); // Сообщаем, что все потоки завершены.
        }
}

---