Помогите придумать способ синхронизации

[PSD]

Есть транспортная структура которая используется для обработки запросов сервером сваязи.
class CTrans
{
   
public:
   bool isComplite; //обрабока заверше
   HANDLE evAck;
   // Завершить обработку запроса в том виде как есть и отдать команду на отсылку ответа слиенту
   int Complete(void);
};



int CTrans::Complete(void)
{
   this->isComplite=true;
    SetEvent(this->evAck);
   return 0;
}


Структура сервера
1) «пайпы» объекты  поддерживающие связь с клиентами через сокет .
На каждого клиента по одному объекту , у каждого объекта 2 потока один  принимает и разбирает  входящий поток формирует  экземпляры  CTrans заполняет служебные поля
Устанавливает isComplite=0; в evAck заносится ид события на котором в WFSO вист второй поток ответственный за отправку ответов на запросы, помешает указатель в свободную ячейку массива и вызывает функцию маршрутизации(котрой передается указатель на экземпляр CTrans ) в результате работы которой  указатель  попадает в очередь одного из каналов. Второй поток сидит в WFSO на событии как только событие происходит он проходит по массиву и для всех CTrans у которых выставлен isComplite==1 формирует ответ и отправляет ответ затем удаляет объект из памяти.

2) «Каналы» крутятся в цикле выбирая по одному  CTrans из очереди выполняют запрос к прибору после чего вызывают CTrans::Complete() и удаляют указатель из свое очереди.


Проблема в том  что вызов CTrans::Complete() может произойти на любом этапе обработки и есть подозрение что периодически  второй поток «пайпа» успевает грохнуть экземпляр CTrans раньше чем произойдет выход из CTrans::Complete();

Есть идеи как можно этого избежать?

[Антон (LogRus)]

PSD, вовесь мютек на входе.
я обычно использую boost::mutex
class CTrans
{
boost::mutex mutex_;   
public:
   bool isComplite; //обрабока заверше
   HANDLE evAck;
   // Завершить обработку запроса в том виде как есть и отдать команду на отсылку ответа слиенту
   int Complete(void);
};

int CTrans::Complete(void)
{
   boost::scoped_lock l(mutex_);
   this->isComplite=true;
    SetEvent(this->evAck);
   return 0;
}

CTrans::~CTrans()
{
   boost::scoped_lock l(mutex_);
   еще что-то чистим
}

соседний поток зависнит на
   boost::scoped_lock l(mutex_);
если кто-то сделал это раньше
mutex_ отпустится при выходе из области видимости l(mutex_) в данном случае из метода когда выйдем тогда и отпустим тоже можно сделать стандартными средствами винды вроде Critical Section и т.п.

[PSD]

Мне тоже приходило в голову использовать мютексы или события но вот в чем вопрос ... а ничего что одновоерменно в ситеме может присудствовать несколько дестяков тысяч объектов CTrans ?

Ведь число обектов ядра вроди как ограничено?

[Антон (LogRus)]

PSD, мьютек в управляющие потоки
и крайний случай сделать его глобальным

сделай внутри CTrans флаг
в деструкторе
while(!complite_flag);

изменение флага в true
поставь перед выходом из complite
то же метод и без мьютексов.

или проверяй флаг из вне CTrans чтение/изменение флага должно быть тоже из вне и закрыто мьютексом который за пределами

CTrans c = new Ctrans;
 
  {
   boost::scoped_lock l(mutex_);
    c->complite;
  }

  {
   boost::scoped_lock l(mutex_);
    if(c->check())
      delete;
  }

как-то так

или еще хранить какой-то объект который будет указывать на последний CTrans для которого вызва complite и вызывать деструктор толко для тех объектов для которых complite вызван опять же обращение к подобному указателю закрыть мьютексом

[Diletant]

Я правильно понял, что речь идет только о сихронизации двух потоков: потока приема данных и потока их обработки. Если так, то поток один поток просто должен ждать завершения другого потока по хэндлу потока. Т.е в CTrans::Complete(void) вставляешь WaitForSingleObject(hThread,...).

Мне тоже приходило в голову использовать мютексы или события но вот в чем вопрос ... а ничего что одновоерменно в ситеме может присудствовать несколько дестяков тысяч объектов CTrans ?

Потоки - это ведь тоже объекты ядра. Такое количество потоков тебя не смущает?

[Антон (LogRus)]

Diletant, ты заблуждаешься, синхронизация поков не подразумевает их уничтожения.
гораздо чаще под синхронизация нужна для кореектного доступа к разделямым потоками данным
простой пример разделямый несколькими потоками объект, изменяет своё состояние вызовом какго-то метода, и объект будет потоко безопасным, если за время выполнения метода не изменится его состояние.
способов как обычно много

[zubr]

Можно и без мутексов обойтись, примерно как Diletant посоветовал:

Код:

if(WaitForSingleObject(hThread, 0)!=WAIT_OBJECT_0)
continue;//переход на следующую итерацию цикла
//код убивающий объект CTrans

[Diletant]

Diletant, ты заблуждаешься, синхронизация поков не подразумевает их уничтожения.
гораздо чаще под синхронизация нужна для кореектного доступа к разделямым потоками данным
простой пример разделямый несколькими потоками объект, изменяет своё состояние вызовом какго-то метода, и объект будет потоко безопасным, если за время выполнения метода не изменится его состояние.
способов как обычно много

В общем случае, это совершенно верно, но ведь в данном конкретном речь идет именно о двух потоках и о том, как при удалении объекта, создаваемом в одном потоке, дождаться завершения обрабтки данных другим потоком. Или я все-таки все не так понял?

[Антон (LogRus)]

Diletant, потоки данных не останавливаются. один примает данные и создаёт объект. один отдаёт данные и уничтожает объект. нужно синхронизировать время жизни объекта данных.

[Diletant]

Я думал, что потоки - это части объекта. А тогда зачем огород с объектам ядра городить? При создании объекта создать две переменные: ПотокОдинПостСдал и ПотокДваПостСдал, и пока оба не станут нулями - уничтожать нельзя. Как менять переменные синхронно, в любой книжке написано.

[Антон (LogRus)]

Diletant, этот вариант был тоже предложен что касается огорода, то полного контекста нет за что расплачиваемся кучей решений программирование это поиск компромисов и выбор из множества решений одного подходящего для конкретной ситуации



ладно это уже общение пошло, а не решение проблемы. PSD уже небось всё сделал.