Вопрос по странному поведению TThread

[Zor]

Ситуация:
Создаю пачку размороженых ниток (TThread[], CreateSuspended = false)

Код

// код потока должен выполнить инит и остановится:
Execute()
{
// init ...
while (!Terminated)
  {
  Suspended = true; // (point:A)
  // something ...
  }
// done ...
}
 
// после создания жду пока все добегут до состояния "заморожено" (или Terminated если облом):
while (1)
  { 
  if (Threads[]->Terminated || Threads[]->Suspended) break;
  }

Так вот, проблема в том, что иногда один-два потока (чаще один) где то застревает, никогда не доходя до (point:A)
WTF? И еще - отладчиком BC6 можно ходить по коду в потоках (F7/F8)?

[OVE]

Попробуйте

Код

while (1)
  { 
  Application->ProcessMessages();
  if (Threads[]->Terminated || Threads[]->Suspended) break;
  }

[serg76]

Создаю пачку размороженых ниток (TThread[], CreateSuspended = false)

можно выложить пример, как создавать потоки в цикле
например for(int i=0;i<7;i++)

[bred]

И еще - отладчиком BC6 можно ходить по коду в потоках (F7/F8)?

В принципе можно, но во-первых нет никакой гарантии что последовательность переключений между потоками будет производится как бы она производилась в нормальном режиме (да и вообще нет гарантии что она вообще будет производится;) ), а во-вторых по большей части такая отладка заканчивается в лучшем случае повисанием ПК с попытками вырубания билдера, захватившего все ресурсы, в течении минут 10 (у меня диспетчер задач однажды убивал билдер порядка 20-30 минут), либо просто перезагрузкой от кнопки "ресет". Кстати перезагружать машину после такой отладки (даже если все вроде прошло чудесно) все равно скорее всего придется .

[Doga]

Привет.

Когда поток замораживается, система просто перестаёт выделять ему процессорное время. Возможно, причина в этом. Попробуйте использовать вместо Suspended какой-либо другой дополнительный флаг для проверки состояния потока.

Если у потока FreeOnTerminate = true, то в случае коректоной обработки флага Terminated, поток может самостоятельно завершить свою работу. Возможно, что Вы пытаетесь обратиться к уже не существующему потоку. Понятно, что последствия, в данном случае, не предсказуемы...

[Zor]

2 OVE я обычно ставлю Sleep() вместо ProcessMessages(). Хотя это мысль - надо исходники порыть...
2 serg76 также как и прочие объекты:
for (int i = 0; i < 7; i++) Threads = new (nothrow) TMyThread(false);

[Zor]

2 Doga ну уж если Suspended криво работает - можно сразу на апи переходить. FrеeOnTerminate не используется - надо же узнать почему поток незапланировано вылетел.

[Doga]

Я не говорил, что Suspended криво работает.

Приведённый Вами код слишком сильно сокращён и не позволят представить полную картину происходящего в потоке. Давайте больше кода

Цель заморозки потоков не понятна. Зачем ожидать заморозки потоков или их завершения сразу после их создания? Не проще ли тогда создать их замороженными?

[Asher]

Привет всем.
Sleep на ожидание отработки может не помочь, с ProcessMessage уже лучше.
Я в таком случае делал цикл ожидания, внутри которого ProcessMessage() и ::SwitchToThread();

[serg76]

Код

for (int i = 0; i < 7; i++) Threads = new (nothrow) TMyThread(false);

эт наверно для тех, кто знал и подзабыл 

и что надо для "nothrow" подключить ?
у меня Undefined symbol

[Zor]

2 serg76 // Threads [ i ] = new ... , ачипятка  
2 Asher проверил - никакой принципиальной разницы между Sleep и ProcessMessages тут нет. Дело вкуса. Разве что без тормоза Sleep лог успевает вырасти в разы больше

*********************************

Всем спасибо разобрался. Дело оказалось во врожденной глючности TThread.
оригинал статьи, если кому интересно: http://delphi.newswhat.com/geoxml/forumhistorythread?groupname=borland.public.delphi.nativeapi.win32&messageid=473950eb@newsgroups.borland.com

А вот виновник торжества:

Код

procedure TThread.Resume;
var
  SuspendCount: Integer;
begin
  SuspendCount := ResumeThread(FHandle);
                                <<<< вот здесь система переключает поток, и если он успевает дойти до Suspend()
                                <<<< флаги состояния показывают фигню.
  CheckThreadError(SuspendCount >= 0);
  if SuspendCount = 1 then
    FSuspended := False;
end;

 напоминает новую реинкарнацию DivideByZero/RunTimeError200, правда?

[serg76]

Вопрос в тему

несколько потоков используют одну ф-ю заполнения listbox

необходимо использовать Критический раздел или достаточно вызывать по Synchronize ?

[bred]

по идее синхронайза должно хватить.

[serg76]

в .h файле mytrd *mtr;
в .cpp

Код

for (i = 0; i < 7; i++) mtr[i]= new (nothrow) mytrd(true);

выдает ошибку: VCL style classes must be constructed using operator new
оператор new есть, что не так 

[Zor]

а целиком?

[serg76]

создаю поток mytrd
идея в том, что у всех потоков одинаковый код, но на стадии инициализации переменным присваиваются разные значения
например "com1","com2","com3" и т.д.

а целиком?

а что целиком?

[bred]

в .h файле mytrd *mtr;
в .cpp

Код

for (i = 0; i < 7; i++) mtr[i]= new (nothrow) mytrd(true);

выдает ошибку: VCL style classes must be constructed using operator new
оператор new есть, что не так 

что-то мне кажется что те надо добавить скобочки в объявление:

Код:

mytrd *mtr[N];

[serg76]

2bred спасибо помогло

в динамическом выделении слабо орентируюсь

а как замутить если кол-во потоков заранее неизвесно ?

[oxotnik]

а как замутить если кол-во потоков заранее неизвесно ?

я так делал, правда через CreateThread  (собственно уже где то размещал):

Код

//в *.hpp главной формы (у меня, а там делай где хочешь)
#include 
using namespace std;
class TMainForm : public TForm
{
...
public:
deque <HANDLE> m_MyThread;
....
};
 
//в *.cpp
 
m_MyThread.push_back(CreateThread( NULL , 0 , SaveDocObj, (LPVOID)id, 0 , NULL )); // помещаем хендл потока в динамический массив
 
//при закрытии формы (приложения) ждем завершения всех потоков:
 
void __fastcall TMainForm::FormCloseQuery(TObject *Sender, bool &CanClose)
{
  if (m_MyThread.size()>0)
     {
       HANDLE *MyThread = new HANDLE[m_MyThread.size()];
       for(unsigned int n=0;n <m_MyThread.size();n++)
          {
            MyThread[n] = m_MyThread[n];
          }
       DWORD hEvent = WaitForMultipleObjects(m_MyThread.size(), MyThread, TRUE, INFINITE);
       delete [] MyThread;
       if (hEvent != WAIT_OBJECT_0)
          {
            CanClose = false;
            return;
          }
     }
 

[serg76]

2oxotnik спасибо, буду грызть