Fix threadring
This commit is contained in:
parent
fae4a9e5ba
commit
8f5cb92f89
1 changed files with 3 additions and 1 deletions
|
@ -13,7 +13,9 @@
|
||||||
use std::os;
|
use std::os;
|
||||||
|
|
||||||
fn start(n_tasks: int, token: int) {
|
fn start(n_tasks: int, token: int) {
|
||||||
let mut (p, ch1) = stream();
|
let (p, ch1) = stream();
|
||||||
|
let mut p = p;
|
||||||
|
let mut ch1 = ch1;
|
||||||
ch1.send(token);
|
ch1.send(token);
|
||||||
// XXX could not get this to work with a range closure
|
// XXX could not get this to work with a range closure
|
||||||
let mut i = 2;
|
let mut i = 2;
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue