斯卡拉Continuations：暂停没有等待/睡眠（）

Question

好吧，我准备放弃这一点。

我想保存一个延续的状态（用shift完成）。 但是，需要注意的是复位后的代码不应执行。考虑工作线程正在执行的延续，应该不再进行处理。继续被保存在可以恢复的全局继续列表中，其后的所有其他事项都被忽略并且不应执行。

工作者线程必须存活（无法中止或销毁需要启动新线程）。

reset { 
    shift { 
    (cont:Unit=>Unit) => 
     println(1) 
     suspend() // how would I implement something like this? 
     cont() 
    } 

    println(3) 
} 

println(2) 

应该产生

1 

恢复延续那么应该产生

3 
2 

---

目前这似乎可能根本不会，因为延续仅限于重置的范围。但我想我会给StackOverflow一个裂缝。

---

编辑：基本上......（也许我应该把这个更早）我想调用一个方法，并暂停执行，直到它准备给我一个结果，我想了一个实现这一偶数循环，而不是线程同步。

Answer 1

我不知道，这是否适用于您的情况，但我这里是如何混合多种复位：

type Proc = Unit => Unit 

    val resume = reset { 
    shift { k1: Proc => 
     reset { 
     shift { k2: Proc => 
      println(1) 
     () => k2(); k1() 
     }   
     println(3) 
     } 
    } 
    println(2) 
    } 
    // 1 

    resume() 
    // 3 
    // 2 

更新： 这里是如何使用方法使用此：

def f(): Unit @cpsParam[Unit,() => Unit] = { 
    println(0) 

    shift { k1: Proc => 
     reset { 
     shift { k2: Proc => 
      println(1) 
     () => k2(); k1() 
     }   
     println(2) 
     } 
    } 

    println(3) 
    } 

    val continue = reset { 
    println(-1) 
    f() 
    println(4) 
    } 

    println("...") 

    continue() 

打印：

-1 
0 
1 
... 
2 
3 
4 

这里是如果你不WA做什么NT暂停通话到f之后一切，直到复位的结局：

reset { 
    println(-1) 
    shift { k: Proc => 
     reset{f()}() 
     k() 
    } 
    println(4) 
    } 

    println("...") 

打印：

-1 
0 
1 
2 
3 
4 
...