Форум

 // Потокобезопасно получаем значение флага приостановки
  TInterlocked.Exchange(Pointer(bs), Pointer(bStop));
  if bs then // Если необходимо
  begin
    WriteLnProtocolIndirect(' Thread Suspended ');
    evResume.WaitFor(); // Приостанавливаем поток
  end;
  while not Terminated do
  begin
    csr.Acquire;// Входим в критическую секцию
    WriteLnProtocolIndirect(' Thread csr Acquire');
    if Assigned(adcR) then // Если инициализирован потоковый интерфейс с АЦП
    begin
//      WriteLnProtocolIndirect('Run');
      adcR.Run; // Вызываем потоковые функции АЦП (Вот здесь выполняются Recv и ProcessData)
    end;
    // Получаем значение флага необходимости копирования
    TInterlocked.Exchange(Pointer(bc), Pointer(bnc));
    if bc then // Если необходимо
    begin
      WriteLnProtocolIndirect('Copy Samples');
      // Здесь копирование в буфер если интерфейс с АЦП передан, указатель
      // на целевой буфер задан и количество данных в допустимых границах
      if Assigned(adc) And Assigned(pCopyData) And (nCopyCount > 0) And
        (nCopyCount <= nMaxCount) then
      begin
        // Копируем
        WriteLnProtocolIndirect('PArms OK'); // Эта функция сбрасывает сообщение в очередь потока - логгера, который записывает в  лог-файл
        adc.getData(pCopyData, nCopyCount);// Копирование в заданный буфер
        WriteLnProtocolIndirect('Copy OK');
        if Assigned(vBuffer) then // Если внутренний буфер инициализирован
        begin
          // Устанавливаем на него указатель копирования по умолчанию
          WriteLnProtocolIndirect('Stay Inner Copy Buffer');
          pCopyData := @vBuffer[0];
          nCopyCount := nMaxCount; // И длину данных сообразно размеру буфера
        end
        else // Иначе
        begin
          pCopyData := nil; // Устанавливаем указатель копирования в нуль
          nCopyCount := 0; // И количество копируемых данных в нуль
        end;


      end;
      // Сбрасываем флаг необходимости копирования (операция разовая)
      TInterlocked.Exchange(Pointer(bnc), Pointer(False));
      WriteLnProtocolIndirect('Clear Copy Flag');
      evCopyAll.SetEvent; // Сигнализируем об окончании копирования
      WriteLnProtocolIndirect('Set Event');
    end;
    csr.Release; // Выходим из критической секции
    WriteLnProtocolIndirect('Thread csr Release');
    // Потокобезопасно получаем значение флага приостановки
    TInterlocked.Exchange(Pointer(bs), Pointer(bStop));
    if bs then // Если необходимо
    begin
      WriteLnProtocolIndirect(' Thread Suspended ');
      evSuspend.SetEvent; // Уведомляем о приостановке потока
      evResume.WaitFor(); // Приостанавливаем поток
    end;
  end;
  WriteLnProtocolIndirect('Thread Terminated');

  Result := 0; // По умолчанию ничего не считано
  // Проверка параметров
  // Если задан внешний буфер необходимо задать и размер копирования
  if Assigned(pData) then
  begin
    if nCount < 1 then
    begin
      Exit;
    end;

    if nCount > nMaxCount then
    begin
      Exit;
    end;
  end;


  csf.Acquire; // Входим в критическую секцию потокобезопасного вызова функции

  // Потокобезопасно получаем значение флага приостановки потока
  TInterlocked.Exchange(Pointer(bs), Pointer(bStop));
  if (not Suspended) And (not bs) then // Если поток выполнения запущен
  begin




      // Входим в критическую секцию атомарного выполнения съема плюс
      // копирование
      WriteLnProtocolIndirect(' READ ADC Try Acquire csr');
      csr.Acquire;
      WriteLnProtocolIndirect('ReadADC Acquire csr');
      // Устанавливаем параметры копирования
      if Assigned(pData) then
      begin
        TInterlocked.Exchange(Pointer(pCopyData), Pointer(pData));
        TInterlocked.Exchange(nCopyCount, nCount);
      end;

      // Сбрасываем предварительно событие окончания съема плюс копирование
      evCopyAll.ResetEvent;
      WriteLnProtocolIndirect('Reset Event OK');
      // Устанавливаем флаг необходимости копирования данных в следующем цикле
      // съема
      TInterlocked.Exchange(Pointer(bnc), Pointer(True));
      WriteLnProtocolIndirect('Set NeedCopy Flag To True');
      csr.Release; // Выходим из критической секции атомарного выполнения
      WriteLnProtocolIndirect('Release csr');
      WriteLnProtocolIndirect(' Wait Copy Event ');
      evCopyAll.WaitFor(); // Ожидаем окончания операции съем плюс копирования

  end;
  csf.Release; // Заканчиваем вызов функции выходом из критической секции