在異步操作里，如異步連接、異步讀寫之類的協(xié)程，co_await這些協(xié)程時需要注意線程切換的細節(jié)。

以asio異步連接協(xié)程為例：

classclient{
public:
client(){
thd_=std::thread([this]{
io_ctx_.run();
});
}

async_simple::Lazyasync_connect(autohost,autoport){
boolret=co_awaitutil::async_connect(host,port);#1
co_returnret;#2
}

~client(){
io_ctx_.stop();
if(thd_.joinable()){
thd_.join();
}
}

private:
asio::io_contextio_ctx_;
std::threadthd_;
};

intmain(){
clientc;
async_simple::syncAwait(c.async_connect());
std::cout<<"quit
";#3
}

這個例子很簡單，client在連接之后就析構(gòu)了，看起來沒什么問題。但是運行之后就會發(fā)生線程join的錯誤，錯誤的意思是在線程里join自己了。這是怎么回事？co_await一個異步連接的協(xié)程，當連接成功后協(xié)程返回，這時候發(fā)生了線程切換。異步連接返回的時候是在io_context的線程里，代碼中的#1在主線程，#2在io_context線程，之后就co_return 返回到main函數(shù)的#3，這時候#3仍然在io_context線程里，接著client就會析構(gòu)了，這時候仍然在io_context線程里，析構(gòu)的時候會調(diào)用thd_.join(); 然后就導致了在io_context的線程里join自己的錯誤。

這是使用協(xié)程時容易犯錯的一個地方，解決方法就是避免co_await回來之后去析構(gòu)client，或者co_await回來仍然回到主線程。這里可以考慮用協(xié)程條件變量，在異步連接的時候發(fā)起一個新的協(xié)程并傳入?yún)f(xié)程條件變量并在連接返回后set_value，主線程去co_await這個條件變量，這樣連接返回后就回到主線程了，就可以解決在io線程里join自己的問題了。

還是以上面的異步連接為例子，需要對之前的async_connect協(xié)程增加一個超時功能，代碼稍作修改：

classclient{
public:
client():socket_(io_ctx_){
thd_=std::thread([this]{
io_ctx_.run();
});
}

async_simple::Lazyasync_connect(autohost,autoport,autoduration){
coro_timertimer(io_ctx_);
timeout(timer,duration).start([](auto&&){});//#1啟動一個新協(xié)程做超時處理
boolret=co_awaitutil::async_connect(host,port,socket_);//假設這里co_await返回后回到主線程
co_returnret;
}

~client(){
io_ctx_.stop();
if(thd_.joinable()){
thd_.join();
}
}


private:
async_simple::Lazytimeout(auto&timer,autoduration){
boolis_timeout=co_awaittimer.async_wait(duration);
if(is_timeout){
asio::error_codeignored_ec;
socket_.shutdown(tcp::shutdown_both,ignored_ec);
socket_.close(ignored_ec);
}

co_return;
}

asio::io_contextio_ctx_;
tcp::socketsocket_;
std::threadthd_;
boolis_timeout_;
};

intmain(){
clientc;
async_simple::syncAwait(c.async_connect("localhost","9000",5s));
std::cout<<"quit
";#3
}

這個代碼增加連接超時處理的協(xié)程，注意#1那里為什么需要新啟動一個協(xié)程，而不能用co_await呢？因為co_await是阻塞語義，co_await會導致永遠超時，啟動一個新的協(xié)程不會阻塞當前協(xié)程從而可以去調(diào)用async_connect。

當timeout超時發(fā)生時就關(guān)閉socket，這時候async_connect就會返回錯誤然后返回到調(diào)用者，這看起來似乎可以對異步連接做超時處理了，但是這個代碼是有問題的。假如異步連接沒有超時會發(fā)生什么？沒有超時的話就返回到main函數(shù)了，然后client就析構(gòu)了，當timeout協(xié)程resume回來的時候client其實已經(jīng)析構(gòu)了，這時候再去調(diào)用成員變量socket_ close將會導致一個訪問已經(jīng)析構(gòu)對象的錯誤。

也許有人會說，那就在co_return之前去取消timer不就好了嗎？這個辦法也不行，因為取消timer，timeout協(xié)程并不會立即返回，仍然會存在訪問已經(jīng)析構(gòu)對象的問題。

正確的做法應該是對兩個協(xié)程進行同步，timeout協(xié)程和async_connect協(xié)程需要同步，在async_connect協(xié)程返回之前需要確保timeout協(xié)程已經(jīng)完成，這樣就可以避免訪問已經(jīng)析構(gòu)對象的問題了。

這個問題其實也是異步回調(diào)安全返回的一個經(jīng)典問題，協(xié)程也同樣會遇到這個問題，上面提到的對兩個協(xié)程進行同步是解決方法之一，另外一個方法就是使用shared_from_this，就像異步安全回調(diào)那樣處理。

還是以異步連接為例：

async_simple::Lazyasync_connect(conststd::string&host,conststd::string&port){
co_returnco_awaitutil::async_connect(host,port);
}

async_simple::Lazytest_connect(){
boolok=co_awaitasync_connect("localhost","8000");
if(!ok){
std::cout<<"connectfailed
";
}

std::cout<<"connectok
";
}

intmain(){
async_simple::syncAwait(test_connect());
}

這個代碼簡單明了，就是測試一下異步連接是否成功，運行也是正常的。如果稍微改一下test_connect：

async_simple::Lazytest_connect(){
autolazy=async_connect("localhost","8000");
boolok=co_awaitlazy;
if(!ok){
std::cout<<"connectfailed
";
}

std::cout<<"connectok
";
}

很遺憾，這個代碼會導致連接總是失敗，似乎很奇怪，后面發(fā)現(xiàn)原因是因為async_connect的兩個參數(shù)失效了，但是寫法和剛開始的寫法幾乎一樣，為啥后面這種寫法會導致參數(shù)失效呢？

原因是co_await一個協(xié)程函數(shù)時，其實做了兩件事：

• 調(diào)用協(xié)程函數(shù)創(chuàng)建協(xié)程，這個步驟會創(chuàng)建協(xié)程幀，把參數(shù)和局部變量拷貝到協(xié)程幀里；

• co_await執(zhí)行協(xié)程函數(shù)；

回過頭來看auto lazy = async_connect("localhost", "8000"); 這個代碼調(diào)用協(xié)程函數(shù)創(chuàng)建了協(xié)程，這時候拷貝到協(xié)程幀里面的是兩個臨時變量，在這一行結(jié)束的時候臨時變量就析構(gòu)了，在下一行去co_await執(zhí)行這個協(xié)程的時候就會出現(xiàn)參數(shù)失效的問題了。

co_await async_connect("localhost", "8000"); 這樣為什么沒問題呢，因為協(xié)程創(chuàng)建和協(xié)程調(diào)用都在一行完成的，臨時變量知道協(xié)程執(zhí)行之后才會失效，因此不會有問題。

問題的本質(zhì)其實是C++臨時變量生命周期的問題。使用協(xié)程的時候稍微注意一下就好了，可以把const std::string&改成std::string，這樣就不會臨時變量生命周期的問題了，如果不想改參數(shù)類型就co_await 協(xié)程函數(shù)就好了，不分成兩行去執(zhí)行協(xié)程。

審核編輯 ：李倩