yammy/uTakeOutThread.pas at main · esisl/yammy · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
unit uTakeOutThread;

interface
uses Classes, uMessageQueue;

type
 TTakeOutThread = class(TThread)                //êëàññ ïîòîêîâ
  private
   queue :TMessageQueue;
   is_work: boolean;
   packet1: string;
    { Private declarations }
  protected
    procedure Execute; override;
  public
    procedure InitThread(pqueue :TMessageQueue);
    procedure EndThread(Sender: TObject);
    procedure CallKernel;
    procedure StopWork;
end;
implementation
 Uses Unit1;
  //Èíèöèàëèçàöèÿ êëàññà-ïîòîêà
//Ïàðàìåòðû:
procedure TTakeOutThread.InitThread(pqueue :TMessageQueue);
begin
   queue := pqueue;
 //  OnTerminate:= EndThread;   //ôóíêöèÿ îêîí÷àíèÿ ïîòîêà
   is_work := true;
end;

procedure TTakeOutThread.StopWork;
begin
  is_work := false;
  queue.FreeTread;
end;

procedure TTakeOutThread.Execute;
var size: integer;
    pack: string;
begin
   while(is_work) do
    begin

      packet1 := queue.Extract;
      if (packet1 <> '') then Synchronize(CallKernel)////Kernel.GetMessageFromServer(pack);//

    end;

//  Terminate;                        //çàâåðøàåì ïðîöåññ
end;

procedure TTakeOutThread.EndThread(Sender: TObject);
var t:integer;
begin
//äîîáðàáîòàòü îñòàâøèåñÿ â î÷åðåäè ñîîáùåíèÿ?
end;

procedure TTakeOutThread.CallKernel;
begin
 fMain.GetMessageFromServer(packet1);

end;

end.