Top.Mail.Ru
Мастера DELPHI, Delphi programming community Титульная страница Поиск, карта сайта Написать письмо 
| Новости | Поиск | FAQ | Статьи | Книги | Новости VCL |
| Форумы ЧАТ | Орешник | KOL и MCK |
Форумы -» Основная («Начинающим»)/ Базы / WinAPI / Компоненты / Сети / Media / Игры / Corba и COM / KOL / FreePascal / .Net / Прочее / RSDN.ORG

« предыдущая ветвь | форум | следующая ветвь »

Как приостановить поток?


Страницы:   1 2 3 4 5 6 7

volser ©   (2005-08-23 12:23:00) 

вот часть кода

В ПОТОКЕ:
 while not Terminated do
 begin
   if not Paused then
   begin
     try
       ExecTick := False;
       ...
     finally
       ExecTick := True;
     end;
   end;
   Sleep(10);
 end;

В ГЛАВНОМ ПОТОКЕ:
 Thread.Paused := True;
 while not Thread.ExecTick do
 begin
   Windows.Beep(500,50);
 end;
 ...
 Thread.Paused := False;

Иногда цикл залипает. В чем проблема?

Defunct   (2005-08-24 01:38:00) [81]

> Alexander Panov

Вполне приличное решение. Даже вероятно в некоторых случаях лучше чем крит. секция.

Только, я бы добавил еще следующее изменение, чтобы после вызова suspend управляющий поток гарантировано мог работать с данными остановленного потока без лишних проверок:

procedure TTest.Suspend;
begin
 fTrySuspend := True;
 while fTrySuspend do
 begin
   sleep(10);
   Application.ProcessMessages
 end
end;

Alexander Panov   (2005-08-24 01:27:00) [82]

ftp://ftp.almar.net.ru/pub/simplethread/simplethread1.zip

Alexander Panov   (2005-08-24 01:25:00) [83]

Defunct ©   (24.08.05 1:07) [57]

Напрямую использовать Suspend потоку все равно не получится.

А вот так можно сделать:

unit Unit1;

interface

uses
 Windows, Messages, SysUtils, Variants, Classes, Graphics, Controls, Forms,
 Dialogs, StdCtrls;

type
 TForm1 = class(TForm)
   Memo1: TMemo;
   Button1: TButton;
   Label1: TLabel;
   Button2: TButton;
   procedure Button1Click(Sender: TObject);
   procedure Button2Click(Sender: TObject);
   procedure FormClose(Sender: TObject; var Action: TCloseAction);
 private
   { Private declarations }
 public
   { Public declarations }
 end;

 TTest=class(Tthread)
 private
   FTrySuspend: Boolean;
   FMemo: TMemo;
   procedure UpdateMemo;
 protected
   procedure Execute; override;
 public
   constructor Create(Memo: TMemo);
   procedure Suspend;
 end;

var
 Form1: TForm1;
 Test: Ttest;
 isTerminate: Boolean;

implementation

{$R *.dfm}

{ TTest }

constructor TTest.Create(Memo: TMemo);
begin
   inherited Create(True);
   FreeOnTerminate := True;
   FMemo := Memo;
   FTrySuspend := False;
   Resume;
end;

procedure TTest.Execute;
begin
   while not Terminated do
   begin
      UpdateMemo;
      Sleep(2000);
      if FTrySuspend then
      begin
        FTrySuspend := False;
        Suspended := True;
      end;
   end;
end;

procedure TTest.Suspend;
begin
   FTrySuspend := True;
end;

procedure TTest.UpdateMemo;
begin
   FMemo.Lines.Add('Доп. поток: состояние расчетов');
end;

procedure TForm1.Button1Click(Sender: TObject);
begin
    Test := TTest.Create(Memo1);
    isTerminate := False;
    while not isTerminate do
    begin
        Test.Suspend;
        while not Test.Suspended do
        begin
            Label1.Caption := 'Основной поток: жду освобождения ресурса';
            Application.ProcessMessages;
            if isTerminate then Break;
        end;
        Memo1.Lines.Add('Основной поток: работаю с Memo1');
        Label1.Caption := 'Основной поток: Работаю';
        Application.ProcessMessages;
        Sleep(1000);
        Test.Resume;
    end;
    Label1.Caption := 'Поток закончил работу';
    Test.Terminate;
end;

procedure TForm1.Button2Click(Sender: TObject);
begin
 IsTerminate := True;
end;

procedure TForm1.FormClose(Sender: TObject; var Action: TCloseAction);
begin
 IsTerminate := True;
end;

end.

Defunct   (2005-08-24 01:07:00) [84]

> Alexander Panov

Пример бесспорно рабочий, но не решает сабжевый вопрос. Всмысле конанду доп потоку на приостановку должен отдавать основной поток. Если можете, подправьте код, (там собсно нечего подправлять, флажек один добавить) было бы интересно и познавательно для всех.

Alexander Panov   (2005-08-24 00:47:00) [85]

Взять пример можно здесь:
ftp://ftp.almar.net.ru/pub/simplethread/simplethread.zip

Alexander Panov   (2005-08-24 00:44:00) [86]

Вот совершенно простой пример:

unit Unit1;

interface

uses
 Windows, Messages, SysUtils, Variants, Classes, Graphics, Controls, Forms,
 Dialogs, StdCtrls;

type
 TForm1 = class(TForm)
   Memo1: TMemo;
   Button1: TButton;
   Label1: TLabel;
   Button2: TButton;
   procedure Button1Click(Sender: TObject);
   procedure Button2Click(Sender: TObject);
   procedure FormClose(Sender: TObject; var Action: TCloseAction);
 private
   { Private declarations }
 public
   { Public declarations }
 end;

 TTest=class(Tthread)
 private
   FMemo: TMemo;
   procedure UpdateMemo;
 protected
   procedure Execute; override;
 public
   constructor Create(Memo: TMemo);
 end;

var
 Form1: TForm1;
 Test: Ttest;
 isTerminate: Boolean;

implementation

{$R *.dfm}

{ TTest }

constructor TTest.Create(Memo: TMemo);
begin
   inherited Create(True);
   FreeOnTerminate := True;
   FMemo := Memo;
   Resume;
end;

procedure TTest.Execute;
begin
   while not Terminated do
   begin
      UpdateMemo;
      Sleep(2000);
      Suspend;
   end;
end;

procedure TTest.UpdateMemo;
begin
   FMemo.Lines.Add('Доп. поток: состояние расчетов');
end;

procedure TForm1.Button1Click(Sender: TObject);
begin
   Test := TTest.Create(Memo1);
   isTerminate := False;
   with Test do
   begin
       while not isTerminate do
       begin
           if Suspended then
           begin
               Memo1.Lines.Add('Основной поток: работаю с Memo1');
               Label1.Caption := 'Основной поток: Работаю';
               Application.ProcessMessages;
               Sleep(1000);
               Resume;
           end;
           while not Suspended do
           begin
               Label1.Caption := 'Основной поток: жду освобождения ресурса';
               Application.ProcessMessages;
           end;
       end;
       Label1.Caption := 'Поток закончил работу';
       Terminate;
   end;
end;

procedure TForm1.Button2Click(Sender: TObject);
begin
 isTerminate := True;
end;

procedure TForm1.FormClose(Sender: TObject; var Action: TCloseAction);
begin
 isTerminate := True;
end;

end.

Fay   (2005-08-23 22:33:00) [87]

2 Alexander Panov ©   (23.08.05 19:09) [53]
Я, конечно, не han_malign, но давно жду такой пример.
Будьте так добры...

Alexander Panov   (2005-08-23 19:09:00) [88]

han_malign ©   (23.08.05 18:27) [52]

Хочешь пример, где можно синхронизацию осуществить методами Suspend/Resume?

han_malign   (2005-08-23 18:27:00) [89]

> Так весь сыр-бор в ветке из-за того, можно или нет обойтись без объектов синхронизации.
- дык Suspend никаким боком к синхронизации и не относится...
This function is primarily designed for use by debuggers. It is not intended to be used for thread synchronization. Calling SuspendThread on a thread that owns a synchronization object, such as a mutex or critical section, can lead to a deadlock if the calling thread tries to obtain a synchronization object owned by a suspended thread. To avoid this situation, a thread within an application that is not a debugger should signal the other thread to suspend itself. The target thread must be designed to watch for this signal and respond appropriately.

Alexander Panov   (2005-08-23 18:02:00) [90]

Leonid Troyanovsky ©   (23.08.05 17:48) [50]
2. Откуда взяться холостым циклам, если поток должен ждать
синхронизирующих событий, т.е., должен спать (уже в терминологии Рихтера).

Так весь сыр-бор в ветке из-за того, можно или нет обойтись безобъектов синхронизации.

Leonid Troyanovsky   (2005-08-23 17:48:00) [91]

> Alexander Panov ©   (23.08.05 17:41) [49]
> Leonid Troyanovsky ©   (23.08.05 17:25) [48]
> Т.е., зачем оно может требоваться для синхронизации,
> если оная уже произошла.

> Например, остановить поток для того, чтобы
> 1. Безопасно работать с другими данными, либо не дать потоку
> захватить другие данные.
> 2. Не разрешать потоку холостых циклов.


Дык,
1. Эта другая задача синхронизации.
2. Откуда взяться холостым циклам, если поток должен ждать
синхронизирующих событий, т.е., должен спать (уже в терминологии Рихтера).

--
Regards, LVT.

Alexander Panov   (2005-08-23 17:41:00) [92]

Leonid Troyanovsky ©   (23.08.05 17:25) [48]
Т.е., зачем оно может требоваться для синхронизации,
если оная уже произошла.

Например, остановить поток для того, чтобы
1. Безопасно работать с другими данными, либо не дать потоку захватить другие данные.
2. Не разрешать потоку холостых циклов.

Leonid Troyanovsky   (2005-08-23 17:25:00) [93]


> Alexander Panov ©   (23.08.05 17:13) [47]

>> тогда и не требуется его усыплять (приостанавливать).

> Не требуется, если это не нужно.
> А если нужно, то никто не мешает это сделать, причем совершенно
> потокобезопасно относительно совместной работы с данными
> этого и других потоков.


Дык, зачем тогда потокобезопасно приостанавливать?
Т.е., зачем оно может требоваться для синхронизации,
если оная уже произошла.

--
Regards, LVT.

Alexander Panov   (2005-08-23 17:13:00) [94]

Leonid Troyanovsky ©   (23.08.05 16:50) [46]
тогда и не требуется его усыплять (приостанавливать).

Не требуется, если это не нужно.
А если нужно, то никто не мешает это сделать, причем совершенно потокобезопасно относительно совместной работы с данными этого и других потоков.

Leonid Troyanovsky   (2005-08-23 16:50:00) [95]


> Alexander Panov ©   (23.08.05 16:45) [45]
> Внук ©   (23.08.05 16:20) [44]
> Не смoжешь ты контролировать, когда именно уснет поток.

> А мне и не нужно знать, когда он уснет после моей команды
> ему. Мне достаточно перед усыплением дождаться, пока поток
> закончит обработку защищаемых данных,


А тогда и не требуется его усыплять (приостанавливать).
Закончил обработку (write) - данные консистентны.

--
Regards, LVT.

Alexander Panov   (2005-08-23 16:45:00) [96]

Внук ©   (23.08.05 16:20) [44]
Не смoжешь ты контролировать, когда именно уснет поток. И дело не в том, кто как пишет программы :) Но через Suspend надежной синхронизации не получится.

А мне и не нужно знать, когда он уснет после моей команды ему. Мне достаточно перед усыплением дождаться, пока поток закончит обработку защищаемых данных, взвести флаг о том, что данные используются в другом потоке, после этого усыпить его. И все. Надежней некуда.

Внук   (2005-08-23 16:20:00) [97]

>>Alexander Panov ©   (23.08.05 15:43) [39]
 Не смoжешь ты контролировать, когда именно уснет поток. И дело не в том, кто как пишет программы :) Но через Suspend надежной синхронизации не получится.

Leonid Troyanovsky   (2005-08-23 16:03:00) [98]


Alexander Panov ©   (23.08.05 15:43) [39]

>> А если он заснет посредине, скажем, Move?

> Он сам заснет, что-ли?


Это не моя терминология.


> Reindeer Moss Eater ©   (23.08.05 14:15) [23]
> Вторичным потоком рулит первичный.
> Он ему делает суспенд.
> Список изменяется только когда вторичный поток уснул.


А остановить его могут на любой атомарной операции.


> Кстати, даже четырехбайтовых значений положено InterLocked*

> Это если используется блокировка Interlocked-функциями.


Дык, и надо ее пользовать. Даже для однобайтовых.

--
Regards, LVT.

Fay   (2005-08-23 15:47:00) [99]

2 Reindeer Moss Eater ©   (23.08.05 15:45) [41]
Я и не утверждаю, что ты стал бы так делать. Просто говорю - так низя.

Reindeer Moss Eater   (2005-08-23 15:45:00) [100]

Fay, что ты мне хочешь доказать?
Что это не лучший способ?
Так я еще с десяток постов назад сказал, что не стал бы так делать.

Страницы:   1 2 3 4 5 6 7

Наверх

Титульная страница Поиск, карта сайта Написать письмо