

DIRECTORY
ForkOps, Process, Xl, XlTQOps, XlTQPrivate;

XlTQOpsImpl: CEDAR PROGRAM
IMPORTS ForkOps, Xl 
EXPORTS Xl, XlTQOps =
BEGIN 

<<Xl.>>TQRep: PUBLIC TYPE = XlTQPrivate.TQRec;

ForkRec: TYPE = RECORD [
tq: Xl.TQ,
proc: Xl.EventProcType,
data: REF ¬ NIL,
event: Xl.Event ¬ NIL
];

ReFork: PROC [data: REF] = {
d: REF ForkRec ¬ NARROW[data];
Xl.Enqueue[d.tq, d.proc, d.data, d.event]
};

EnqueueSoon: PUBLIC PROC [ms: INT ¬ 0, tq: Xl.TQ, proc: Xl.EventProcType, data: REF ¬ NIL, event: Xl.Event ¬ NIL] = {
d: REF ForkRec ¬ NEW[ForkRec ¬ [tq: tq, proc: proc, data: data, event: event]];
ForkOps.ForkDelayed[ms: ms, proc: ReFork, data: d, priority: Process.priorityForeground];
};

CountProcs: PUBLIC PROC [tq: Xl.TQ] RETURNS [n: CARD] = {
n ¬ tq.eventCount;
IF tq.selfRunning OR tq.lockCount>0 THEN n ¬ n+1;  --count multiple locks as one; but I don't know whether it matters
};
END.

  f  XlTQOpsImpl.mesa
Copyright Ó 1991, 1992 by Xerox Corporation.  All rights reserved.
Christian Jacobi, March 11, 1991 4:17 pm PST
Christian Jacobi, April 19, 1993 10:51 am PDT
--Like Xl.Enqueue but delayed by approximatively ms millliseconds.
--Time delay like in DelayedFork.ForkSoon.
Not monitored; but defs says that number might change anytime...

 Ê¿  •NewlineDelimiter
–(cedarcode) style˜ code™Kšœ
Ïeœ7™BKšœ,™,K™-—K˜ šÏk	˜	K˜+K˜ —šÏnœžœž˜Kšžœ˜Kšžœ˜—Kšžœ˜K˜ Kšœžœžœ˜.K˜ šœ	žœžœ˜Kšœ
˜
Kšœ˜Kšœžœžœ˜Kšœž˜Kšœ˜K˜ —šŸœžœžœ˜Kšœžœžœ˜Kšœ)˜)Kšœ˜K˜ —šŸœžœžœžœ/žœžœžœ˜uKšœB™BK™*Kšœžœžœ;˜OK˜YKšœ˜—K˜ šŸ
œžœžœ	žœžœžœ˜9Kšœ@™@Kšœ˜KšžœžœžœÏcB˜uK˜K™ —Kšžœ˜K˜ — …—    x    