::: 델파이 Tip&Trick :::

델파이 Tip&Trick 성격에 맞지 않는 광고,비방,질문의 글은 즉시 삭제하며
내용을 복사하여 사용할 경우 반드시 이곳(http://www.howto.pe.kr)을 출처로 명시하여 주세요


Category

  김영대(2003-08-18 19:13:16, Hit : 6188, Vote : 1361
 http://www.howto.pe.kr
 thread-safe Queue 구현

unit Unit1;

interface

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

Type
  TQueueThread = class(TThread)
  private
    FGuardian: TCriticalSection;
    Flist: TStringList;
  protected
    procedure Execute; override;
  public
    constructor Create; virtual;
    destructor Destroy; override;
    function Lock: TStringList;
    procedure UnLock;
    procedure Push(const S: String);
    function Pop: String;
    function IsEmpty: Boolean;
    procedure ClearAll;
  end;
    
type
  TForm1 = class(TForm)
    Memo1: TMemo;
    Memo2: TMemo;
    Timer1: TTimer;
    Button1: TButton;
    Button2: TButton;
    procedure FormCreate(Sender: TObject);
    procedure Button1Click(Sender: TObject);
    procedure Button2Click(Sender: TObject);
    procedure Timer1Timer(Sender: TObject);
    procedure FormCloseQuery(Sender: TObject; var CanClose: Boolean);
  private
    { Private declarations }
  public
    { Public declarations }
    qthr: TQueueThread;
  end;

var
  Form1: TForm1;

implementation
{$R *.dfm}

constructor TQueueThread.Create;
begin
  inherited Create(True);
  FGuardian:= TCriticalSection.Create;
  FLIst:= TStringList.Create;
end;

destructor TQueueThread.Destroy;
begin
  FList.Free;
  FGuardian.Free;
  inherited;
end;

function TQueueThread.Lock: TStringList;
begin
  FGuardian.Acquire; // pthread_mutex_lock()
  Result := Flist;
end;

procedure TQueueThread.UnLock;
begin
  FGuardian.Release; // pthread_mutex_unlock()
end;

procedure TQueueThread.Push(Const S: String);
begin
  Lock;
  try
    FList.Add(S);
    if Suspended then
      Resume; // 자료가 들어왔으므로 다시 일시작 // pthread_cond_signal()
  finally
    UnLock;
  end;
end;

function TQueueThread.Pop: String;
begin
  Lock;
  try
    if Flist.Count > 0 then
    begin
      Result := FList[0];
      FList.Delete(0);
    end
    else
      Result := EmptyStr;
  finally
    Unlock;
  end;
end;

function TQueueThread.IsEmpty: Boolean;
begin
  Lock;
  try
    Result := FList.Count = 0;
  finally
    Unlock
  end;
end;

procedure TQueueThread.ClearAll;
begin
  Lock;
  try
    FList.Clear;
  finally
    UnLock;
  end;
end;

procedure TQueueThread.Execute;
begin
  while not Terminated do
  begin
    while not IsEmpty do
    begin
      // Queue에 쌓여있는 자료가 있다면 처리
      Form1.Memo2.Lines.Add(pop);
      Application.ProcessMessages;
    end;

    sleep(3000); // Queue에 일정 자료가 쌓이도록 잠시 재움
    
    if not Terminated Then
      Suspend; // pthread_cond_wait()
  end;
end;

procedure TForm1.FormCreate(Sender: TObject);
begin
  Timer1.Enabled := False;
  Timer1.Interval := 1000; // 1초마다 생산

  qthr := TQueueThread.Create;
end;

procedure TForm1.FormCloseQuery(Sender: TObject; var CanClose: Boolean);
begin
  Timer1.Enabled := False;
  qthr.Terminate;
  qthr.WaitFor;
end;

procedure TForm1.Button1Click(Sender: TObject);
begin
  qthr.resume;

  Timer1.Enabled := True;
end;

procedure TForm1.Button2Click(Sender: TObject);
begin
  qthr.suspend;

  Timer1.Enabled := False;
end;

procedure TForm1.Timer1Timer(Sender: TObject);
begin
  Timer1.Tag := Timer1.Tag+1;

  Memo1.Lines.Add(IntToStr(Timer1.Tag));
  qthr.push(IntToStr(Timer1.Tag)); // 임의의 자료을 Queue에 넣는다
end;

end.





211   [윈도우즈 API] 콤포넌트의 Hint 에 그림(Bitmap) 넣기  김영대 2003/04/11 5230 1360
210   [일반/컴포넌트] 키보드의 Shift+Tab 이 눌린것처럼 처리하기  김영대 2003/04/14 4766 1312
209   [윈도우즈 API] 폼이 Minimized 되었을때 깜박이게 하기 2  김영대 2003/04/14 6017 1324
208   [COM/OLE] 그리드 자료 엑셀로 좀더 빠르게 보내기  공성환 2003/04/16 5560 976
207   [일반/컴포넌트] C에서 한글자르기  공성환 2003/04/16 4880 973
206   [COM/OLE] 기존 Excel 문서 불러와서 편집후 저장하기  김영대 2003/04/18 5504 1293
  [일반/컴포넌트] thread-safe Queue 구현  김영대 2003/08/18 6188 1361
204   [알고리즘] 숫자를 KB, MB, GB 단위로 환산하기  김영대 2003/11/13 5102 1172
203   [일반/컴포넌트] StrToFloatDef  김영대 2003/11/13 5002 1259
202   [알고리즘] 구분자(delimiter)를 사용한 문자열 파싱(parsing)  김영대 2003/11/13 5209 1149
201   [일반/컴포넌트] thread-safe Queue를 이용한 TLogThread  김영대 2003/11/18 4854 1143
200   [네트웍/인터넷] IOCP(I/O Completion Port) class  김영대 2003/11/18 11080 884
199   [네트웍/인터넷] Winsock WriteFile and Overlapped IO  김영대 2003/11/18 5463 1235
198   [시스템] 윈도우즈 서비스 목록 구하기  김영대 2004/07/22 4627 1240
197   [시스템] 윈도우즈 서비스 상태 구하기  김영대 2004/07/22 5037 1284
196   [시스템] 윈도우즈 서비스 시작/중지 하기  김영대 2004/07/22 6199 1553
195   [시스템] 윈도우즈 시스템의 스크롤바 두께 바꾸기  김영대 2004/07/24 5658 1386
194   [시스템] 마우스 아래의 윈도우 핸들 구하기  김영대 2004/07/24 9459 1987
193   [시스템] 내 프로그램의 실행 우선순의 바꾸기  김영대 2004/07/24 5155 1399
192   [윈도우즈 API] 내 프로그램의 화면을 가리는 프로그램 리스트  김영대 2004/07/24 4598 1210
191   [윈도우즈 API] Taskbar 의 특정 위치에 popup 메뉴 띄우기  김영대 2004/07/24 4627 1207
190   [윈도우즈 API] Taskbar 의 위치 추적하기  김영대 2004/07/24 4032 1072
189   [일반/컴포넌트] 윈도우즈"시작" 버튼위에 글씨 쓰기  김영대 2004/07/24 4210 1156
188   [시스템] 제어판의 모든 applet 정보 구하기  김영대 2004/07/24 4458 1141
187   [윈도우즈 API] 바로 직전에 active 되었던 윈도우와 콘트롤 구하기  김영대 2004/07/24 4667 1175
186   [윈도우즈 API] 지원하는 키보드 입력 언어 구하고 변경하기  김영대 2004/07/24 4767 1275
185   [윈도우즈 API] 현재 키보드 입력 언어 구하기  김영대 2004/07/24 5017 1364
184   [COM/OLE] 윈도우즈 "작업 표시줄 및 시작 메뉴 등록 정보" 화면  김영대 2004/07/25 6103 1639
183   [COM/OLE] 윈도우즈 "인터넷 등록 정보" 화면  김영대 2004/07/25 4279 1331
182   [COM/OLE] 윈도우즈 "날짜/시간 등록 정보" 화면  김영대 2004/07/25 6425 1654
181   [COM/OLE] 윈도우즈 "검색: 파일 또는 폴더" 화면  김영대 2004/07/25 5006 1402
180   [COM/OLE] 윈도우즈 "시스템 종료" 화면  김영대 2004/07/25 4621 1312
179   [COM/OLE] 윈도우즈 "모든 창을 최소화"  김영대 2004/07/25 6263 1717
178   [일반/컴포넌트] TList 를 이용한 stack 구조 구현  김영대 2004/07/25 4402 1146
177   [윈도우즈 API] 폼에 애니메이션 효과 주기  김영대 2004/07/25 4685 1240
176   [일반/컴포넌트] 모서리가 둥근(rounded ends) TMemo 만들기  김영대 2004/07/25 4632 1191
175   [시스템] 로컬 가상 드라이버(substitution device) 만들고 제거하기  김영대 2004/07/25 6148 1335
174   [네트웍/인터넷] 네트워크 드라이브 연결 화면 띄우기  김영대 2004/07/26 5979 1609
173   [일반/컴포넌트] TProgressbar 의 색상 바꾸기  김영대 2004/07/26 4646 1242
172   [일반/컴포넌트] TTrewView, TListView 를 이미지로 저장하기  김영대 2004/07/26 4381 965

[이전 10개] [1]..[11][12][13][14][15][16][17][18][19] 20 ..[25] [다음 10개]
 

Copyright 1999-2022 Zeroboard / skin by zero