fpcsrc/tests/test/tmt1.pp


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

{ %version=1.1 }

{$mode objfpc}

uses
  sysutils
{$ifdef unix}
  ,cthreads
{$endif}
  ;

const
{$ifdef cpuarm}
  {$define slowcpu}
{$endif cpuarm}

{$ifdef slowcpu}
   threadcount = 40;
   stringlen = 2000;
{$else slowcpu}
   threadcount = 100;
   stringlen = 10000;
{$endif slowcpu}

var
   finished : longint;
threadvar
   thri : longint;

function f(p : pointer) : ptrint;
  var
     s : ansistring;
  begin
     writeln('thread ',longint(p),' started');
     thri:=0;
     while (thri<stringlen) do
      begin
        s:=s+'1';
        inc(thri);
      end;
     writeln('thread ',longint(p),' finished');
     InterLockedIncrement(finished);
     f:=0;
  end;

var
   i : ptrint;
   started: longint;
begin
   finished:=0;
   started:=0;

   for i:=1 to threadcount do
     if BeginThread({$ifdef fpc}@{$endif}f,pointer(i)) <> tthreadid(0) then
       inc(started);

   while finished<started do
     {$ifdef wince}sleep(10){$endif};
   writeln(finished);
end.