bob体育app同步异步和阻塞4-同步非阻塞

2019-12-14 07:07栏目:bob体育app
TAG:

连串简单介绍和code见《bob体育平台,一齐异步和鸿沟2-测验小项目》

 

bob体育app,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(卡塔尔(قطر‎未归来前,”Stop”开关向来是不可用的,同时UI分界面也被封堵(同步形式的老毛病卡塔尔国。

bob体育app 1

1> 在联合具名非梗塞情势下,尽管IO Result还尚无结果,却得以见到不断前行的”Progress”(这里由于不知晓IO什么日期截至,实际是眼前的用掉的小运),那样顾客能够清楚尽管UI卡住了,但最少程序还是没挂掉的,那正是不打断下能多干一些任何有含义的政工带给的功利。

2> 假若IO未有提供timeout的装置(如本例中的IO(卡塔尔国),也足以在轮询中设置多个最大的轮询时间,防止OnStart(卡塔尔平素不回来,导致主线程(超级多时候都是UI)不可能健康运转。

3> 轮询格局中利用了四线程,那样实在落到实处了IO并发,在五个IO管理中,能够收缩全部IO职责管理的总时间

之所以从客户体验上来看,同步非拥塞格局是要优于同步窒碍格局的。

本来,这里存在叁个轮询间距的标题,平素轮询或轮询间距小,CPU会大方消耗在无太多意义的轮询code上,假若轮询间隔设得过大,如1s,但假设IO实际到位的年月独有10ms,那么实际上IO的成就时间会延伸到1s,那反而不比一齐阻塞格局了。

版权声明:本文由bob体育app发布于bob体育app,转载请注明出处:bob体育app同步异步和阻塞4-同步非阻塞