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
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
|
program ThreadedIPC;
{$mode objfpc}{$H+}
uses
{$IFDEF UNIX}cthreads,{$ENDIF}
SysUtils, Classes, Math, FGL, SimpleIPC;
const
ServerUniqueID = '39693DC0-BD8B-4AAD-9D9B-387D37CD59FD';
ServerTimeout = 5000;
ClientDelayMin = 500;
ClientDelayMax = 3000;
ClientCount = 10;
var
ServerThreaded: Boolean = True;
type
TServerMessageHandler = class
public
procedure HandleMessage(Sender: TObject);
procedure HandleMessageQueued(Sender: TObject);
end;
procedure TServerMessageHandler.HandleMessage(Sender: TObject);
begin
WriteLn(TSimpleIPCServer(Sender).StringMessage);
end;
procedure TServerMessageHandler.HandleMessageQueued(Sender: TObject);
begin
TSimpleIPCServer(Sender).ReadMessage;
end;
procedure ServerWorker;
var
Server: TSimpleIPCServer;
MessageHandler: TServerMessageHandler;
begin
WriteLn(Format('Starting server #%x', [GetThreadID]));
MessageHandler := TServerMessageHandler.Create;
Server := TSimpleIPCServer.Create(nil);
try
Server.ServerID := ServerUniqueID;
Server.Global := True;
Server.OnMessage := @MessageHandler.HandleMessage;
Server.OnMessageQueued := @MessageHandler.HandleMessageQueued;
Server.StartServer(ServerThreaded);
if ServerThreaded then
Sleep(ServerTimeout)
else
while Server.PeekMessage(ServerTimeout, True) do ;
except on E: Exception do
WriteLn('Server error: ' + E.Message);
end;
Server.Free;
MessageHandler.Free;
WriteLn(Format('Finished server #%x', [GetThreadID]));
end;
procedure ClientWorker;
var
Client: TSimpleIPCClient;
Message: String;
begin
WriteLn(Format('Starting client #%x', [GetThreadID]));
Client := TSimpleIPCClient.Create(nil);
try
Client.ServerID := ServerUniqueID;
while not Client.ServerRunning do
Sleep(100);
Client.Active := True;
Sleep(RandomRange(ClientDelayMin, ClientDelayMax));
Message := Format('Hello from client #%x', [GetThreadID]);
Client.SendStringMessage(Message);
except on E: Exception do
WriteLn('Client error: ' + E.Message);
end;
Client.Free;
WriteLn(Format('Finished client #%x', [GetThreadID]));
end;
type
TThreadList = specialize TFPGObjectList<TThread>;
var
I: Integer;
Thread: TThread;
Threads: TThreadList;
begin
Randomize;
WriteLn('Threaded server: ' + BoolToStr(ServerThreaded, 'YES', 'NO'));
Threads := TThreadList.Create(True);
try
Threads.Add(TThread.CreateAnonymousThread(@ServerWorker));
for I := 1 to ClientCount do
Threads.Add(TThread.CreateAnonymousThread(@ClientWorker));
for Thread in Threads do
begin
Thread.FreeOnTerminate := False;
Thread.Start;
end;
for Thread in Threads do
Thread.WaitFor;
finally
Threads.Free;
end;
end.
|
