同步非阻塞

2019-12-02 18:41 来源:未知

品种简要介绍和code见《一齐异步和拥塞2-测量检验小项目》

 

1. 实现

由于IO是堵塞的,所以要贯彻轮询IO的结果,须求将IO放入线程中拍卖,IO的管理结果作为给线程的exit code重回。这里用“CBaseThread”轻松的将线程管理函数封装到类中

unsigned CSyncIOByPolling::ThreadWork()
{
    return IO();
}

 

在OnStart(卡塔尔中,先逐风姿浪漫运营2个线程管理IO,然后轮询,风姿罗曼蒂克旦有此外一个IO的线程管理达成后就发送结果

为了不把CPU占满,这里每首轮询设了三个sleep的时刻间距,然后经过NotifyProgress(卡塔尔(قطر‎函数公告UI当前的快慢。

bool CSyncIOByPolling::OnStart()
{
    int        nRetArray[] = {-1, -1};
    HANDLE    hThreadArray[] = {NULL, NULL};

    int        nThreadNum = sizeof(hThreadArray) / sizeof(hThreadArray[0]);
    for (int i = 0; i < nThreadNum; i++)
    {
        hThreadArray[i] = StartThread();
    }

    int        nIndex = 0;
    int        nCompletedNum = 0;

    //polling get IO result
    while (true)
    {
        for (int i = 0; i < nThreadNum; i++)
        {
            if (hThreadArray[i])
            {
                NotifyProgress(nIndex, i);
                DWORD    dwExitCode = STILL_ACTIVE;
                if(::GetExitCodeThread(hThreadArray[i], &dwExitCode))
                {
                    if (STILL_ACTIVE != dwExitCode)
                    {
                        nRetArray[i] = dwExitCode;
                    }
                    else
                    {
                        continue;
                    }
                }

                ::CloseHandle(hThreadArray[i]);
                hThreadArray[i] = NULL;
                NotifyResult(nRetArray[i], i);
                nCompletedNum++;
            }
        }

        if (nCompletedNum >= nThreadNum)
        {
            break;
        }

        Sleep(TIMER_ELAPSE);
        nIndex += TIMER_ELAPSE;
    }

    return    true;
}

大概的从代码长度来看,同步非阻塞情势就明摆着比同步拥塞格局要复杂。

 

2. 测试

和同盟拥塞方式同样,在OnStart(卡塔尔(英语:State of Qatar)未归来前,”Stop”按键一向是不可用的,同偶然候UI分界面也被卡住(同步方式的老毛病卡塔尔。

图片 1

1> 在合营非拥塞格局下,即便IO Result还从未结果,却足以看来不断前行的”Progress”(这里由于不知情IO何时截至,实际是现阶段的用掉的时日),那样顾客能够领悟固然UI卡住了,但起码程序依然没挂掉的,那正是不打断下能多干一些其余有含义的事务带给的补益。

2> 借使IO未有提供timeout的安装(如本例中的IO(卡塔尔国),也得以在轮询中装置多少个最大的轮询时间,幸免OnStart(卡塔尔(英语:State of Qatar)一直不回来,导致主线程(相当多时候都是UI)不能够健康运行。

3> 轮询情势中应用了二十八线程,这样其实贯彻了IO并发,在多个IO管理中,能够减少全体IO职分处理的总时间

故而从客商体验上来看,同步非梗塞情势是要优于同步堵塞方式的。

自然,这里存在一个轮询间距的标题,一贯轮询或轮询间距小,CPU会大方消耗在无太多意义的轮询code上,要是轮询距离设得过大,如1s,但若是IO实际到位的光阴唯有10ms,那么实际上IO的到位时间会延伸到1s,那反而不及一齐阻塞方式了。

TAG标签:
版权声明:本文由金沙澳门唯一官网发布于金沙澳门唯一官网,转载请注明出处:同步非阻塞