斯卡拉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 
...