windows 线程同步学习测试-1

#include <span>"</span><span>stdafx.h</span><span>"</span><span>using</span> std::cout; <span>using</span> std::endl; <span>using</span><span> std::cin;

unsigned __stdcall ThreadFunRun(</span><span>void</span> * paData)<span>//</span><span>vs默认是__cdecl 调用</span><span>{
    </span><span>int</span> *iData = (<span>int</span>*<span>)paData;
    </span><span>for</span> (<span>int</span> index = <span>0</span>; index < <span>100000000</span>; ++<span>index)
    {
        (</span>*iData)++<span>;
    }
    </span><span>//</span><span>cout <<"线程函数中"<< *iData << endl;</span><span>return</span><span>0</span><span>;
}

</span><span>using</span><span> std::vector;

vector</span><HANDLE> createThread(<span>int</span> &<span>ivalue)
{
    vector</span><HANDLE><span> vecH;
    </span><span>const</span><span>int</span> iThrCount = <span>2</span><span>;
    </span><span>for</span> (<span>int</span> index = <span>0</span>; index < iThrCount; ++<span>index)
    {
        HANDLE hpt1 </span>=<span> (HANDLE)_beginthreadex(
            NULL,</span><span>//</span><span>SECURITY_ATTRIBUTES</span><span>0</span>,<span>//</span><span>cbStackSize</span><span>            ThreadFunRun,
            </span>&<span>ivalue,
            </span><span>0</span><span>,
            NULL
            );
        vecH.push_back(hpt1);
    }

    </span><span>return</span><span> vecH;
}

</span><span>bool</span> waitForRun(vector<HANDLE> &<span> hs)
{
    </span><span>for</span> (<span>int</span> index = <span>0</span>; index < hs.size(); ++<span>index)
    {
        DWORD dwaitRes </span>=<span> WaitForSingleObject(hs[index], INFINITE);
        </span><span>if</span> (dwaitRes !=<span>WAIT_FAILED)
        {
            CloseHandle(hs[index]);
        }
        </span><span>else</span><span>
        {
            cout </span><< <span>"</span><span>等待时出错，出错ID：</span><span>"</span> << GetLastError() <<<span> endl;
            </span><span>for</span> (; index < hs.size();++<span>index)
            {
                CloseHandle(hs[index]);
            }
            </span><span>return</span><span>false</span><span>;
        }
    }

    </span><span>return</span><span>true</span><span>;
}
</span><span>int</span> _tmain(<span>int</span> argc, _TCHAR*<span> argv[])
{


    </span><span>const</span><span>int</span> icount = <span>50</span><span>;
    </span><span>for</span> (<span>int</span> index = <span>0</span>; index < icount; ++<span>index)
    {
        </span><span>int</span> ivCalc = <span>0</span><span>;
        vector</span><HANDLE>  hsGet =<span> createThread(ivCalc);
</span><span>//</span><span>        Sleep(60);
</span><span>//</span><span>        cout << ivCalc << endl;</span><span>if</span><span> (waitForRun(hsGet))
             cout </span><< ivCalc <<<span> endl;
         </span><span>else</span><span>
             cout</span><<<span>"</span><span>第 </span><span>"</span><<index << <span>"</span><span> 次等待线程结束出错</span><span>"</span> <<<span> endl;
  }
 </span><span>return</span><span>0</span><span>;
 }</span>