99国产精品久久久久久久成人热,精品久久久噜噜噜久久久,日产精品久久久久久久

協程（Coroutine）與線程類似，可看成用戶線程，由用戶調度，而不是系統調度。

示例創建1W個協程對象（TestCoro），然后隨機調度運行。

1W個協程運行于同一個線程中。

協程構造綁定到CoroFun(), 與boost::thread的創建相同。

#include <iostream>
#include <vector>

#include <boost/bind.hpp>
#include <boost/coroutine/all.hpp>
#include <boost/make_shared.hpp>
#include <boost/shared_ptr.hpp>

using namespace std;

// test coroutine class
class TestCoro
{
public:
    explicit TestCoro(int i);
    ~TestCoro();

public:
    void operator()();
    bool IsCompleted() const { return !m_coro; }

private:
    typedef boost::coroutines::coroutione<void ()> Coro;

private:
    void CoroFun(Coro::caller_type & ca);

private:
    int m_i;
    Coro m_coro;
    Coro::caller_type * m_pCa;
};

TestCoro::TestCoro(int i)
: m_i(i)
, m_pCa(NULL)
{
    cout << "TestCoro(" << i << ")" << endl;
    m_coro = Coro(boost::bind(&TestCoro::CoroFun, this, _1));
}

TestCoro::~TestCoro()
{
    cout << "~TestCoro(" << m_i << ")" << endl;
}

void TestCoro::operator()()
{
    m_coro();
}

void TestCoro::CoroFun(Coro::caller_type & ca)
{
    m_pCa = &ca;

    for (int i = 0; i < 10; i++)
    {
        BOOST_ASSERT(m_pCa == &ca);
        (*m_pCa)();
        cout << m_i << " - " << i << endl;
    }
}

int main()
{
    typedef boost::shared_ptr<TestCoro> TestCoroPtr;
    typedef std::vector<TestCoroPtr> TestCoroVec;
    TestCoroVec v;
    for (int i = 0; i < 10000; i++)
        v.push_back(boost::make_shared<TestCoro>(i));

    cout << "Start coroutines." << endl;

    while (!v.empty)
    {
        size_t idx = rand() % v.size();
        TestCoroPtr & pCoro = v[idx];
        (*pCoro)();
        if (pCoro->IsCompleted())
        {
            v[idx] = v[v.size() - 1];
            v.pop_back();
        }
    }

    cout << "Coroutines ended." << endl;
    return 0;
}

posted on 2013-11-22 12:10 金慶閱讀(832) 評論(0) 編輯收藏引用所屬分類: 1. C/C++

只有注冊用戶登錄后才能發表評論。
【推薦】100%開源！大型工業跨平臺軟件C++源碼提供，建模，組態！

相關文章: How are dtLinks created in NavMesh C++ parameter passing rules Naming Conventions for Accessors Visual Studio 2019 Compiler Hangs Fbx File Format Identifier 查找內存錯誤 std::thread 中的異常會丟失調用棧用賦值代替 protobuf CopyFrom() vs2017 linux 編譯輸出改成 vs 格式為 LiteIDE 添加選中標記

網站導航: 博客園 IT新聞 BlogJava 博問 Chat2DB 管理

金慶的專欄

公告

留言簿(12)

隨筆分類(502)

隨筆檔案(423)

相冊

搜索

積分與排名

最新評論

閱讀排行榜

評論排行榜