java_threadpool/ThreadPool_rs/
Future_rs.rs

1use std::sync::mpsc::Receiver;
2
3pub struct  Future {
4    pub receiver: Receiver<String>
5}
6
7impl Future {
8    pub fn get(self) {
9
10        match self.receiver.recv(){
11            Ok(end) => {
12                match end.as_str() {
13                    "end" => (),
14                    _ => println!("报错了")
15                }
16            },
17            Err(e) => println!("{:#?}", e)
18        }
19    }
20}