利用临界区的多线程同步测试

核心提示：本文示例源代码或素材下载 测试的思路我先后启动10个线程，每个线程都往一个文本文件(1.txt)中写自己的信息，利用临界区的多线程同步测试，每个线程写100次，每次信息包括它的线程id，由于当一个线程写入的时候，其他线程必须等待，以及时间，并用两条横线将一条信息包括起来

本文示例源代码或素材下载

测试的思路

我先后启动10个线程，每个线程都往一个文本文件(1.txt)中写自己的信息，每个线程写100次。每次信息包括它的线程id，以及时间，并用两条横线将一条信息包括起来。

测试步骤

选择同步和不选择同步，各测试一次。

测试结果

当不选择同步时，我们可以发现在记录的文本中每条信息的两条横线没有一一对应，排列混乱。

选择同步时，我们可以发现在记录的文本中每条信息的两条横线一一对应，并且按顺序排列。程序耗时较多。

结论

当利用临界区同步时，同一时刻每次只有一个线程可以往文件中写入信息，这样可以保证每条信息的完整。

由于当一个线程写入的时候，其他线程必须等待，所以同步时耗时也较多。

主要代码如下

//建一个供测试使用的文件类

class CMyfile
{
public:
　　CMyfile()
　　{
　　　　
　　　　InitializeCriticalSection(&cs);
　　}
　　~CMyfile()
　　{
　　　　DeleteCriticalSection(&cs);
　　}
　　void msglog(char* buffer,int length,int wait)
　　{
　　　　static int i=0;
　　　　CString a;
　　　　a.Format("%d#",i++);
　　　　if (m_bSync) EnterCriticalSection(&cs);
　　　　fwrite("\n", 1, 1, fstream);
　　　　fwrite(a+CString(''-'',50), 52, 1, fstream);
　　　　fwrite("\n", 1, 1, fstream);
　　　　fwrite(buffer, length, 1, fstream);　　
　　　　Sleep(wait);
　　　　fwrite("\n", 1, 1, fstream);
　　　　fwrite(a+CString(''-'',50), 52, 1, fstream);
　　　　fflush(fstream);
　　 　　if (m_bSync) LeaveCriticalSection(&cs);
　　
　　}
　　bool openfile(CString filename,bool bSync)
　　{
　　　　m_filename=filename;
　　　　m_bSync=bSync;
　　　　if((fstream=fopen(filename, "wt")) == NULL)
　　　　　　return false ;
　　　　else
　　　　　　return true;
　　}
　　void closefile()
　　{
　　　　fclose(fstream);
　　　　
　　}
protected:
　　 CRITICAL_SECTION cs;
　　 FILE* fstream;
　　 CString m_filename;
　　 bool m_bSync;
　　
private:
};

测试代码：

UINT threadFunc( LPVOID p);
void CBDlg::OnButton2()
{
　　// TODO: Add your control notification handler code here
　　
　　CMyfile file;
　　if (m_sync.GetCheck()==1)
　　　 file.openfile("1.txt",true);//同步
　　else
　　　 file.openfile("1.txt",false);//异步
　　 CWinThread* thd[10];
　　 HANDLE hThd[10];
　　 for(int i=0;i<10;i++)
　　 {
　　thd[i]=AfxBeginThread(threadFunc,&file);
　　
　　//故意制造线程启动时间的不一致
　　Sleep(10);
　　hThd[i]=thd[i]->m_hThread;
　　 }
　　 //等待所有线程结束
　　 WaitForMultipleObjects(10,hThd,true,INFINITE);
　　
　　 file.closefile();
　　 AfxMessageBox("ok");
　　
}
UINT threadFunc( LPVOID p)
{
　　CMyfile* file=(CMyfile*)p;
　　long lThreadID = ::AfxGetThread()->m_nThreadID;
　　CString a;
　　a.Format("thread %d",lThreadID);
　　
　　for (int i=0;i<100;i++)
　　{
　　CTime time=CTime::GetCurrentTime();
　　CString str=time.Format("%y-%m-%d %H:%M:%S");
　　str=str+"--------->"+a;
　　file->msglog(str.GetBuffer(str.GetLength()),str.GetLength(),lThreadID/100);
　　 }
　 return 1;　　
}