3d Game Walkman

3d图形渲染,网络引擎 — tonykee's Blog
随笔 - 45, 文章 - 0, 评论 - 309, 引用 - 0
数据加载中……

多线程中MutiRead/SingleWrite互斥的实现(原创)

今天晚上总算有点收获,写服务器,要用到(多读/单写)互斥,也就是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;
}

 

posted on 2008-01-09 01:10 李侃 阅读(910) 评论(7)  编辑 收藏 引用 所属分类: 网络模块

评论

# re: 多线程中MutiRead/SingleWrite互斥的实现(原创)  回复  更多评论   

看了一会儿,理论上貌似可行,但是实际上效率应该还是不足。因为粒度依然没有划分明确。
2008-01-09 10:20 | draracle

# re: 多线程中MutiRead/SingleWrite互斥的实现(原创)  回复  更多评论   

这种办法很容易导致写饥饿...
一般来说写的优先级应该比读高一些
2008-01-09 16:24 | eXile

# re: 多线程中MutiRead/SingleWrite互斥的实现(原创)  回复  更多评论   

而且你的这种实现存在死锁的可能性, 即使不死锁,也会使线程反复切换,效率不高
2008-01-09 16:28 | eXile

# re: 多线程中MutiRead/SingleWrite互斥的实现(原创)  回复  更多评论   

死锁倒应该不会,但是活锁是难以避免了。
2008-01-09 16:30 | 空明流转

# re: 多线程中MutiRead/SingleWrite互斥的实现(原创)  回复  更多评论   

恩,看来这是一个很糟糕的实现,我再想想办法看
2008-01-09 19:30 | 李侃

# re: 多线程中MutiRead/SingleWrite互斥的实现(原创)  回复  更多评论   

请参考ACE或者Boost中的读写锁
2008-01-25 00:24 | 罗宾李

# re: 多线程中MutiRead/SingleWrite互斥的实现(原创)  回复  更多评论   

编程尽可能避免多线程, 1来调试不方便, 2来线程切换降低了总体效率(特别是多核的主流机器)

要在 游戏本身的设计上减少线程之间数据共享
2009-01-11 13:29 | llxisdsh

只有注册用户登录后才能发表评论。
网站导航: 博客园   IT新闻   BlogJava   知识库   博问   管理