3d Game Walkman

今天晚上總算有點收獲，寫服務器，要用到（多讀/單寫）互斥，也就是MutiRead/SingleWrite互斥的實現，采用用非信號量來實現，用戶模式，非內核模式，實現高效的線程調度

源代碼如下：

// ThreadTest.cpp : 定義控制臺應用程序的入口點。
//

#include "stdafx.h"
#include <process.h>
#include <windows.h>
#include <stdio.h>

//關鍵區鎖
class MemLock {
 CRITICAL_SECTION _crisection;
public:
 MemLock(){
  InitializeCriticalSection( &_crisection );
 }

 ~MemLock(){
  DeleteCriticalSection( &_crisection );    
 }

 void lock() {
  EnterCriticalSection( &_crisection );     
 }

 void unlock() {
  LeaveCriticalSection( &_crisection );     
 }
};

//共用資源
class ShareSource
{
 MemLock mlock;
 volatile LONG    g_bResourceUse;
 volatile LONG    g_bResourceUse1;

 int j;

public:
   ShareSource()
   {
      g_bResourceUse = 0;
   g_bResourceUse1 = 0;
   }
   void read(char *user)
   {
 
  while(InterlockedIncrement(&g_bResourceUse)>0)
  {
   if(g_bResourceUse1==0)
   {
    printf("用戶%s 開始讀 ",  user);
    Sleep(100);
    printf("用戶%s 正在讀..", user);
    Sleep(100);
    printf("用戶%s 讀完了 \r\n",  user);
    Sleep(100);
   }
   InterlockedDecrement(&g_bResourceUse);
   Sleep(10);
   //printf("%d \r\n", j);
  } 
   }

   void write(char *user)
   {
    mlock.lock();
     while(InterlockedIncrement(&g_bResourceUse1)>0 )
  {
     if(g_bResourceUse==0)
  {
   printf("[用戶%s 開始寫..", user);
   Sleep(100);
   printf("用戶%s 正在寫..", user);
   Sleep(100);
   printf("用戶%s 寫完了]..\r\n", user);
   Sleep(100);
  }
  InterlockedDecrement(&g_bResourceUse1); 
  Sleep(10);
  }
  mlock.unlock();
   }
};

class ThreadTest
{
public:
 char user[20];
    ShareSource * share;
 HANDLE hThread;
    ThreadTest(char *_user, ShareSource * source)
 {
    strcpy(user, _user); //用戶名
       hThread = 0;
    share = source;
 }

 //工作線程的方法
 static unsigned __stdcall  WorkThreadCallBackMothodRead(LPVOID param) {
  
   ThreadTest *th  = (ThreadTest *) param;
   while(1)
   th->share->read(th->user);
  
  return 0;
 }

 //工作線程的方法
 static unsigned __stdcall  WorkThreadCallBackMothodWrite(LPVOID param) {
  
      ThreadTest *th  = (ThreadTest  *) param;
   while(1)
   th->share->write(th->user);
  
  return 0;
 }

 //開始讀線程
 void BeginReadThread()
 {
       hThread = (HANDLE) _beginthreadex(0, 0, ThreadTest::WorkThreadCallBackMothodRead, (LPVOID)this , 0, 0);
 }

 //開始寫線程
 void BeginWriteThread()
 {
  hThread = (HANDLE) _beginthreadex(0, 0, ThreadTest::WorkThreadCallBackMothodWrite, (LPVOID)this , 0, 0);
 }

};

int _tmain(int argc, _TCHAR* argv[])
{

 ShareSource source;
    ThreadTest T1("T1", &source);
 ThreadTest T2("T2", &source);
 ThreadTest T3("T3", &source);
 
 //前面兩個讀
 T1.BeginReadThread();
 T2.BeginReadThread();
 
 //最后一個線程寫
 T3.BeginWriteThread();

 getchar();
 return 0;
}