-
Notifications
You must be signed in to change notification settings - Fork 2
/
ServerModule.pas
111 lines (86 loc) · 2.4 KB
/
ServerModule.pas
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
unit ServerModule;
interface
uses
IdThreadSafe,
MainModule,
System.SyncObjs,
Classes, SysUtils, uniGUIServer, uniGUIMainModule, uniGUIApplication, uIdCustomHTTPServer,
uniGUITypes, UniProvider, PostgreSQLUniProvider, Data.DB, DBAccess, Uni, MemDS,
Vcl.ExtCtrls, uniGUIBaseClasses, uniGUIClasses, uniTimer;
type
TUniServerModule = class(TUniGUIServerModule)
procedure UniGUIServerModuleCreate(Sender: TObject);
procedure UniGUIServerModuleDestroy(Sender: TObject);
private
FMsgSenderThreads: TArray<TThread>;
FTerminator: TIdThreadSafeBoolean;
protected
procedure FirstInit; override;
public
end;
function UniServerModule: TUniServerModule;
implementation
{$R *.dfm}
uses
UniGUIVars;
function UniServerModule: TUniServerModule;
begin
Result:=TUniServerModule(UniGUIServerInstance);
end;
procedure TUniServerModule.FirstInit;
begin
InitServerModule(Self);
end;
procedure TUniServerModule.UniGUIServerModuleCreate(Sender: TObject);
var
thread: TThread;
t: Integer;
begin
FTerminator := TIdThreadSafeBoolean.Create;
FTerminator.Value := False;
for t := 0 to 9 do
FMsgSenderThreads := FMsgSenderThreads + [TThread.CreateAnonymousThread(
procedure
var
i: Integer;
session: TUniGUISession;
mainModule: TUniMainModule;
begin
while not FTerminator.Value do
begin
SessionManager.Sessions.Lock;
for i := 0 to SessionManager.Sessions.SessionList.Count-1 do
begin
session := TUniGuiSession(SessionManager.Sessions.SessionList[i]);
mainModule := TUniMainModule(session.UniMainModule);
if Assigned(mainModule) then
begin
mainModule.MsgQueue.PushItem(TThread.CurrentThread.Handle.ToHexString + ' - ' + DateTimeToStr(Now));
end;
end;
SessionManager.Sessions.Unlock;
Sleep(1000);
end;
end
)];
for thread in FMsgSenderThreads do
begin
thread.FreeOnTerminate := False;
thread.Start;
end;
end;
procedure TUniServerModule.UniGUIServerModuleDestroy(Sender: TObject);
var
thread: TThread;
begin
FTerminator.Value := True;
for thread in FMsgSenderThreads do
begin
thread.WaitFor;
thread.Free;
end;
FTerminator.Free;
end;
initialization
RegisterServerModuleClass(TUniServerModule);
end.