rust学习（tokio协程分析二）

例子：

我们如果使用new_current_thread来创建tokio的协程运行runtime时，

let rt = tokio::runtime::Builder::new_current_thread().enable_all().build().unwrap();

发现只有调用rt.block_on(...)才能触发。这里我们分析一下为何在new_current_thread的runtime下无法运行的原因。

代码1

fn testCoroutine4() {
    thread::spawn(||{
        let rt = tokio::runtime::Builder::new_current_thread().enable_all().build().unwrap();
        let guard1 = rt.enter();
        println!("trace1", );
        rt.spawn(doSayHi());
        println!("trace2", );
        rt.spawn(doSayHi());
        println!("trace3", );
    }).join();
}

这个无法运行的情况是由于执行完最后代码println!("trace3", );之后，线程直接就退出了，没有机会做调用栈切换。

根据代码1的情况，我们考虑是否可以保持线程不退出（如代码2），这样是否可以执行到协程（doSayHi）呢？

代码2：

fn testCoroutine5() {
    thread::spawn(||{
        let rt = tokio::runtime::Builder::new_current_thread().enable_all().build().unwrap();
        let guard1 = rt.enter();
        println!("trace1", );
        rt.spawn(doSayHi());
        println!("trace2", );
        rt.spawn(doSayHi());
        println!("trace3", );
 
        thread::sleep(Duration::from_secs(10));
    }).join();
}

和遗憾，还是没有运行doSayHi,这是为什么呢？因为thread::sleep直接把线程sleep了，协程的调用栈也没有被切换。

我们来看一下可以运行的代码：

代码3：

fn testCoroutine6() {
    thread::spawn(||{
        let rt = tokio::runtime::Builder::new_current_thread().enable_all().build().unwrap();
        let guard1 = rt.enter();
        println!("trace1", );
        let v1 = rt.spawn(doSayHi());
        println!("trace2", );
        let v2 = rt.spawn(doSayHi());
        println!("trace3", );
 
        rt.block_on(v1);
        rt.block_on(v2);
    }).join();
}

输出：

我们可以看到可以正常打印了。所以我们来想一下协程需要依赖哪些情况才能运行：

1.没有退出的线程

2.有切换调用栈的入口

按照上面的思路，我们是否不用block_on(v1)也能保证协程运行能？其实是可以的，参看

fn testCoroutine4() {
    thread::spawn(||{
        let rt = tokio::runtime::Builder::new_current_thread().enable_all().build().unwrap();
        let guard1 = rt.enter();
        println!("trace1", );
        rt.spawn(doSayHi());
        println!("trace2", );
        rt.spawn(doSayHi());
        println!("trace3", );
 
        loop {
            rt.block_on(async {
                println!("sleep start", );
                time::sleep(Duration::from_secs(10)).await;
                println!("sleep end", );
            });
        }
    }).join();
}

哈哈，可以看到，线程最后启动了一个和之前毫无关系的协程代码，里面只是一个sleep（注意！！这个是tokio的sleep），这个sleep的作用就是满足线程有一个协程切换的入口点。我们运行一下看看结果：

正常运行。不过这个代码只是用来验证我们对协程的认识，不建议正式代码中使用。

总结：

之前用过C语言的libco，它的原理是通过注册了libc的大部分posix的io操作函数，然后通过epoll来实现异步io来实现。例如读取socket的数据，如果没有数据，由于是异步io，所以直接切换到下一个调用栈。这样就实现了简单的协程。rust这块貌似对整个协程做了统一的接口管理？在协程中的sleep等操作一定要调用tokio的接口，否则就会直接造成卡死。哈哈。不过如果是multi_thread的话，实际上也没啥关系，就是直接将协程变成了线程操作，程序应该不会出现卡死。