3

这是一个示例程序:

extern crate futures;
extern crate tokio_core;

use futures::{Async, Future, Stream};
use tokio_core::reactor::Core;
use tokio_core::net::TcpListener;

fn main() {
    let mut core = Core::new().unwrap();

    futures::sync::oneshot::spawn(
        TcpListener::bind(&"127.0.0.1:5000".parse().unwrap(), &core.handle())
            .unwrap()
            .incoming()
            .for_each(|_| {
                println!("connection received");
                Ok(())
            }),
        &core,
    );

    let ft = futures::future::poll_fn::<(), (), _>(|| {
        std::thread::sleep_ms(50);
        Ok(Async::NotReady)
    });

    core.run(ft);
}

如您所见,我调用oneshot::spawn然后立即删除它的返回值,理论上应该取消其中包含的未来。但是,当我运行这个程序然后连接到 时127.0.0.1:5000,它仍然会打印“已收到连接”。为什么这样做?我希望它不会打印任何东西并TcpListener从端口中删除 , 解除绑定。

4

1 回答 1

4

这是crate中的一个(现已修复)错误futures;版本0.1.18应该包括修复。

它使用keep_running: boolin SpawnHandle/的反转值Executor

于 2018-01-21T11:10:30.420 回答