SCM Repository
Diff of /sml/trunk/src/cm/compile/concur.sml
Parent Directory
| 
Revision Log
| 
Patch
| revision 450, Fri Oct 22 17:10:09 1999 UTC | revision 451, Sat Oct 23 15:05:55 1999 UTC | |
|---|---|---|
| # | Line 24 | Line 24 |
| 24 | val inputReady : TextIO.instream -> unit cond | val inputReady : TextIO.instream -> unit cond |
| 25 | val ucond : unit -> unit cond | val ucond : unit -> unit cond |
| 26 | val signal : unit cond -> unit | val signal : unit cond -> unit |
| 27 | ||
| 28 | (* forget all waiting threads and input conditions *) | |
| 29 | val reset : unit -> unit | |
| 30 | end | end |
| 31 | ||
| 32 | structure Concur :> CONCUR = struct | structure Concur :> CONCUR = struct |
| # | Line 47 | Line 50 |
| 50 | val runable : tstate queue = ref ([], []) | val runable : tstate queue = ref ([], []) |
| 51 | val inputs = ref ([]: (unit cond * OS.IO.poll_desc) list) | val inputs = ref ([]: (unit cond * OS.IO.poll_desc) list) |
| 52 | ||
| 53 | fun reset () = (runable := ([], []); inputs := []) | |
| 54 | ||
| 55 | (* we heavily favor non-I/O conditions, but that's ok for our purposes *) | (* we heavily favor non-I/O conditions, but that's ok for our purposes *) |
| 56 | ||
| 57 | fun wakeup (ref (Arrived _), _) = | fun wakeup (ref (Arrived _), _) = |
|
||||||||
| root@smlnj-gforge.cs.uchicago.edu | ViewVC Help |
| Powered by ViewVC 1.0.0 |
