Movatterモバイル変換


[0]ホーム

URL:


Skip to content

Navigation Menu

Sign in
Appearance settings

Search code, repositories, users, issues, pull requests...

Provide feedback

We read every piece of feedback, and take your input very seriously.

Saved searches

Use saved searches to filter your results more quickly

Sign up
Appearance settings

Code rust concurrency

Huon Wilson edited this pageNov 14, 2013 ·2 revisions
use std::cell::Cell;use std::comm::SharedChan;fnload_image(url: ~str) -> ~[u8]{    ~[0,1,2]}// Object://fn load_image(url: ~str) -> ~[u8];enumImageLoaderMsg{LoadImage(~str,Chan<~[u8]>),Exit}fnmain(){let urlto_load = ~"foo.png";let(port, chan) =stream::<ImageLoaderMsg>();    do spawn{        loop{            match port.recv(){LoadImage(url, result_chan) =>{let image =load_image(url);                    result_chan.send(image);}Exit =>break}}}// make a load image requestlet shared_chan =SharedChan::new(chan);for _inrange(0,10){let new_chan = shared_chan.clone();do spawn{            let(result_port, result_chan) =stream();            new_chan.send(LoadImage(~"image.png", result_chan));let image = result_port.recv();println!("{:?}", image);}}    shared_chan.send(Exit);}

Clone this wiki locally


[8]ページ先頭

©2009-2025 Movatter.jp