java_threadpool/ThreadPool_rs/
Future_rs.rs

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
use std::sync::mpsc::Receiver;

pub struct  Future {
    pub receiver: Receiver<String>
}

impl Future {
    pub fn get(self) {

        match self.receiver.recv(){
            Ok(end) => {
                match end.as_str() {
                    "end" => (),
                    _ => println!("报错了")
                }
            },
            Err(e) => println!("{:#?}", e)
        }
    }
}