unit utThreadPool;

interface

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

type
  TForm_CatchWC = class(TForm)
    lvWC: TListView;
    lvEmploye: TListView;
    btnAddWC: TButton;
    btnAddEmploye: TButton;
    btnAddM: TButton;
    btnStart: TButton;
    procedure FormCreate(Sender: TObject);
    procedure btnStartClick(Sender: TObject);
    procedure btnAddWCClick(Sender: TObject);
    procedure btnAddEmployeClick(Sender: TObject);
    procedure btnAddMClick(Sender: TObject);
  private
    { Private declarations }
    hMutex : THandle;  //互斥句柄
    WCArr : array of dword;  //厕所
    myMsg : dword;      //自定义消息
    FActived : boolean;   //是否开抢
    WC, Employe : integer;  //当前厕所与员工的匹配情况
    //添加员工
    procedure AddEmploye(const ARoleName: string);
  public
    { Public declarations }
  end;

var
  Form_CatchWC: TForm_CatchWC;

implementation

{$R *.dfm}
//使用WC  每人限用50秒
function UseWC(index : integer): integer; stdcall;
var
  i, vWC, vEmploye : integer;
  msg : TMsg;
begin
  while GetMessage(msg, 0, 0, 0) do
  begin
    if msg.message = Form_CatchWC.myMsg then
    begin
      vEmploye := Form_CatchWC.Employe;
      vWC := Form_CatchWC.WC;

      for i := 1 to 50 do
      begin
        sleep(200);
        WaitForSingleObject(Form_CatchWC.hMutex,INFINITE);
        Form_CatchWC.lvEmploye.Items.Item[vEmploye].SubItems[2] := inttostr(i);
        ReleaseMutex(Form_CatchWC.hMutex);
      end;
      Form_CatchWC.lvWC.Items[vWC].SubItems[0] := '空闲';
    end;
  end;
end;
//分配WC  优先经理M
function AssignWC(index : integer): integer; stdcall;
var
  i, j : integer;
  JobFound : boolean;
begin
  while true do
  begin
    sleep(500);
    if Form_CatchWC.FActived then
    begin
      JobFound := False;
      for i := 0 to Form_CatchWC.lvWC.Items.Count - 1 do
      begin
        if Form_CatchWC.lvWC.Items[i].SubItems[0] = '空闲' then
        begin
        //经理优先
          for j := 0 to Form_CatchWC.lvEmploye.Items.Count - 1 do
          begin
            if (Form_CatchWC.lvEmploye.Items[j].SubItems[0] = 'M') and (Form_CatchWC.lvEmploye.Items[j].SubItems[1] = '等待') then
            begin
              //可以如厕时, WC牌号和员工牌号
              Form_CatchWC.WC := i;
              Form_CatchWC.Employe := j;
              //调整员工, WC状态
              Form_CatchWC.lvWC.Items.Item[i].SubItems[0] := '使用';
              Form_CatchWC.lvEmploye.Items.Item[j].SubItems[1] := '入厕';
              //给线程发送消息, 告知如厕
              PostThreadMessage(Form_CatchWC.WCArr[i], Form_CatchWC.myMsg, 0, 0);
              //当前厕所已占用, 只能找其他厕所了
              JobFound := True;
              break;
            end;
          end;

          if JobFound then Break;
          //经理先蹲, 然后员工
          for j := 0 to Form_CatchWC.lvEmploye.Items.Count - 1 do
          begin
            if (Form_CatchWC.lvEmploye.Items[j].SubItems[0] = 'E') and (Form_CatchWC.lvEmploye.Items[j].SubItems[1] = '等待') then
            begin
              Form_CatchWC.WC := i;
              Form_CatchWC.Employe := j;

              Form_CatchWC.lvWC.Items.Item[i].SubItems[0] := '使用';
              Form_CatchWC.lvEmploye.Items.Item[j].SubItems[1] := '入厕';
              PostThreadMessage(Form_CatchWC.WCArr[i], Form_CatchWC.myMsg, 0, 0);
              JobFound := True;
              break;
            end;
          end;
        end;
        if JobFound then break;
      end;
    end;
  end;
end;

procedure TForm_CatchWC.AddEmploye(const ARoleName : string);
var
  item : TListItem;
  i : integer;
  uThread : THandle;
begin
  //增加员工等待线程
  SetLength(WCArr, Length(WCArr) + 1);

  CreateThread(nil, 0, @UseWC, nil, 0, uThread);
  WCArr[Length(WCArr) - 1] := uThread;
  with lvEmploye.Items.Add do
  begin
    Caption := '员工' + inttostr(Length(WCArr) - 1);
    SubItems.Add(ARoleName);
    SubItems.Add('等待');
    SubItems.Add('0');
  end;
end;

procedure TForm_CatchWC.btnAddEmployeClick(Sender: TObject);
begin
  AddEmploye('E');
end;

procedure TForm_CatchWC.btnAddMClick(Sender: TObject);
begin
  AddEmploye('M');
end;

procedure TForm_CatchWC.btnAddWCClick(Sender: TObject);
begin
  with lvWC.Items.Add do
  begin
    Caption := '厕所' + inttostr(lvWC.Items.Count + 1);
    SubItems.Add('空闲');
  end;
end;

procedure TForm_CatchWC.btnStartClick(Sender: TObject);
begin
  FActived := True;
end;

procedure TForm_CatchWC.FormCreate(Sender: TObject);
var
  uThread : dword;
  i : integer;
  item : TListItem;
begin
  hMutex := CreateMutex(0, false,'hMutex');
  myMsg := WM_USER + 1;

  lvWC.Clear;
  with lvWC.Items.Add do
  begin
    Caption := '厕所' + inttostr(lvWC.Items.Count);
    SubItems.Add('空闲');
  end;

  lvEmploye.Clear;
  AddEmploye('E');
  AddEmploye('E');
  AddEmploye('M');
  //创建分配厕所的线程
  windows.CreateThread(nil,0,@AssignWC,nil,0,uThread);
  FActived := False;
end;

end.


//delphi/6207