WorkerThreadsTest.mesa
Copyright Ó 1993 by Xerox Corporation. All rights reserved.
Created by Christian Jacobi, April 2, 1993
Christian Jacobi, April 20, 1993 6:37 pm PDT
This is used to debug the WorkerThreads package.
DIRECTORY
Commander,
CommanderOps,
Convert,
IO,
Process,
Rope,
TerminalIO,
WorkerThreads;
WorkerThreadsTest:
CEDAR
MONITOR
IMPORTS Commander, CommanderOps, Convert, IO, Process, Rope, TerminalIO, WorkerThreads ~
BEGIN
lastNumber: INT ¬ 0;
GetNumber:
ENTRY
PROC []
RETURNS [n:
REF
INT] = {
n ¬ NEW[INT ¬ lastNumber];
lastNumber ¬ lastNumber+1;
};
mustAbort: BOOL ¬ FALSE;
MustAbort:
ENTRY
PROC []
RETURNS [b:
BOOL] = {
b ¬ mustAbort;
mustAbort ¬ FALSE
};
pool: WorkerThreads.Pool ¬ WorkerThreads.CreatePool[3];
pauseLength: INT ¬ 5000; --milliseconds
activities: LIST OF WorkerThreads.Activity ¬ NIL;
CreatePool: Commander.CommandProc ~ {
ENABLE Convert.Error => CommanderOps.Failed["needs integer percentage"];
i: INT;
i ¬ Convert.IntFromRope[CommanderOps.NextArgument[cmd]];
pool ¬ WorkerThreads.CreatePool[percentage: i];
TerminalIO.PutF1["Pool created: %g\n", IO.int[i]];
};
SetMSec: Commander.CommandProc ~ {
ENABLE Convert.Error => CommanderOps.Failed["needs integer milliseconds"];
i: INT;
i ¬ Convert.IntFromRope[CommanderOps.NextArgument[cmd]];
pauseLength ¬ i;
TerminalIO.PutF1["Pause set to: %g milliseconds\n", IO.int[i]];
};
ResetActivities: Commander.CommandProc ~ {
activities ¬ NIL;
mustAbort ¬ FALSE;
TerminalIO.PutRope["Activities reset\n"];
};
Abort: Commander.CommandProc ~ {
TerminalIO.PutRope["Set abort flag\n"];
mustAbort ¬ TRUE;
};
ForkOne: Commander.CommandProc ~ {
activity: WorkerThreads.Activity;
number: REF INT ¬ GetNumber[];
TerminalIO.PutF1["Fork no: %g\n", IO.int[number]];
activity ¬ WorkerThreads.Fork[pool, Forkee, number];
activities ¬ CONS[activity, activities];
};
Forkee:
PROC [x:
REF] ~ {
number: REF INT ¬ NARROW[x];
TerminalIO.PutF1["Start perform: %g\n", IO.int[number]];
Process.PauseMsec[pauseLength];
IF MustAbort[]
THEN {
TerminalIO.PutF1["Will abort: %g\n", IO.int[number]];
ERROR ABORTED
};
TerminalIO.PutF1["Finish perform: %g\n", IO.int[number]];
};
Help1: Commander.CommandProc ~ {
al: LIST OF WorkerThreads.Activity ¬ activities;
IF al=
NIL
THEN
IO.PutRope[cmd.out, "Failed Help1\n"]
ELSE {
activities ¬ al.rest;
TerminalIO.PutRope["Start Help1\n"];
WorkerThreads.Perform[al.first];
TerminalIO.PutRope["Finish Help1\n"];
};
};
Wait: Commander.CommandProc ~ {
al: LIST OF WorkerThreads.Activity ¬ activities;
TerminalIO.PutRope["Start Wait\n"];
activities ¬ NIL;
WorkerThreads.Wait[al];
TerminalIO.PutRope["Finish Wait\n"];
};
Comment: Commander.CommandProc ~ {
r: Rope.ROPE ¬ CommanderOps.NextArgument[cmd];
r ¬ Rope.Cat["-- ", r, "\n"];
TerminalIO.PutRope[r];
};
Commander.Register["WorkerThreadsCreatePool", CreatePool, "Test of WorkerThreads"];
Commander.Register["WorkerThreadsSetMSec", SetMSec, "Test of WorkerThreads"];
Commander.Register["WorkerThreadsResetActivities", ResetActivities, "Test of WorkerThreads"];
Commander.Register["WorkerThreadsForkOne", ForkOne, "Test of WorkerThreads"];
Commander.Register["WorkerThreadsHelp1", Help1, "Test of WorkerThreads"];
Commander.Register["WorkerThreadsWait", Wait, "Test of WorkerThreads"];
Commander.Register["WorkerThreadsComment", Comment, "Test of WorkerThreads"];
Commander.Register["WorkerThreadsAbort", Abort, "Test of WorkerThreads"];
END.