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
|
implement Seq, Mainmodule;
include "sys.m";
sys: Sys;
include "draw.m";
include "sh.m";
include "alphabet/reports.m";
include "alphabet.m";
alphabet: Alphabet;
Value: import alphabet;
Seq: module {};
typesig(): string
{
return "rr*-a-o";
}
init()
{
sys = load Sys Sys->PATH;
alphabet = load Alphabet Alphabet->PATH;
}
quit()
{
}
run(nil: ref Draw->Context, nil: ref Reports->Report, nil: chan of string,
opts: list of (int, list of ref Alphabet->Value),
args: list of ref Alphabet->Value): ref Alphabet->Value
{
stop := -1;
for(; opts != nil; opts = tl opts){
case (hd opts).t0 {
'a' =>
stop = 0;
'o' =>
stop = 1;
}
}
spawn seqproc(r := chan of string, args, stop);
return ref Value.Vr(r);
}
seqproc(r: chan of string, args: list of ref Alphabet->Value, stop: int)
{
status := "";
if(<-r == nil){
pid := sys->pctl(0, nil);
sys->print("%d. seq %d args\n", pid, len args);
for(; args != nil; args = tl args){
sr := (hd args).r().i;
sys->print("%d. started\n", pid);
sr <-= nil;
status = <-sr;
sys->print("%d. got status\n", pid);
if((status == nil) == stop)
break;
}
}else
r = nil;
for(; args != nil; args = tl args)
(hd args).r().i <-= "die!";
if(r != nil)
r <-= status;
}
|
