blob: b1b81d09522ff0c4760585b78fe852d456f3d96c (
plain) (
blame)
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
|
package scala.tools.nsc
package util
/** A class of work items to be used in interrupt requests.
* Todo: we should replace the Eithers by Futures or Try's.
*/
abstract class InterruptReq {
/** The result type of the operation
*/
type R
/** The operation to be performed */
protected val todo: () => R
type Continuation = Either[R, Throwable] => Unit
/** The result provided */
private var result: Option[Either[R, Throwable]] = None
/** The continuations waiting asynchronously on a provided result */
private var waiting: List[Continuation] = Nil
/** To be called from interrupted server to execute demanded task */
def execute(): Unit = synchronized {
try {
result = Some(Left(todo()))
} catch {
case t: Throwable => result = Some(Right(t))
} finally {
notify()
for (k <- waiting.reverse) k(result.get)
}
}
/** To be called from interrupting client to get result for interrupt */
def getResult(): R = synchronized {
while (result.isEmpty) {
try {
wait()
} catch { case _ : InterruptedException => () }
}
result.get match {
case Left(res) => res
case Right(t) => throw new FailedInterrupt(t)
}
}
def onComplete(k: Continuation) = synchronized {
if (result.isDefined)
k(result.get)
else
waiting = k :: waiting
}
}
class FailedInterrupt(cause: Throwable) extends Exception("Compiler exception during call to 'ask'", cause)
|
