开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > Windows编程 > 进程与线程 > 查看源码
DerivedThread.cpp
资源名称：RWLock.zip　[点击查看]
上传用户：jnsxzc
上传日期：2007-01-03
资源大小：25k
文件大小：2k
源码类别：

进程与线程

开发平台：

Visual C++

DerivedThread.cpp：源码内容
  1. // DerivedThread.cpp: implementation of the CDerivedThread class.
  2. //
  3. //////////////////////////////////////////////////////////////////////
  5. #include "stdafx.h"
  6. #include "TestLock.h"
  7. #include "DerivedThread.h"
  9. #ifdef _DEBUG
  10. #undef THIS_FILE
  11. static char THIS_FILE[]=__FILE__;
  12. #define new DEBUG_NEW
  13. #endif
  15. char CDerivedThread::g_szStringToUpdate[128];
  16. int  CDerivedThread::g_nWriteLockAccesses = 0;
  17. int  CDerivedThread::g_nReadLockAccesses = 0;
  19. //---------------------------------------------------------------------
  20. // run() - overrides run method of base class and provides the test for
  21. // read-write locking of a global string.
  22. //
  23. // Exceptions   : NONE
  24. // Return Codes : NONE
  25. //---------------------------------------------------------------------
  26. ///////////////////////////////////////////////////////////////////////
  27. void CDerivedThread::run()
  28. ///////////////////////////////////////////////////////////////////////
  29. {
  30. char szWriterMessage[64];
  31. char szReaderMessage[128];
  33. sprintf(szWriterMessage, "Last written by thread #%ld", m_lThreadId);
  35. sprintf(szReaderMessage, "Read by thread #%ld : ", m_lThreadId);
  36. int nReadMessageLen = strlen(szReaderMessage);
  38. if (m_bReader)
  39. {
  40. // 100-ms object test time so that write threads are not starved... 
  41. // this delay must be viewed "as other work done by thread"
  42. while (WaitForSingleObject(m_hShutdownEvent, 300) != WAIT_OBJECT_0)
  43. {
  44. // Reader thread functionality
  45. m_pcLock->lockRead();
  47. InterlockedIncrement((long *)&g_nReadLockAccesses);
  49. // read message from global string
  50. sprintf(&szReaderMessage[nReadMessageLen], "%s; Read Lock Accesses %d; Write Lock Accesses %d", 
  51. g_szStringToUpdate, g_nReadLockAccesses, g_nWriteLockAccesses);
  53. m_pcLock->unlockRead();
  55. // The list box should be protected by a mutex... but this is only a test app
  56. // Do NOT measure performance of read-write locks using this list box.
  57. m_pcListBox->AddString(szReaderMessage);
  58. }
  59. }
  60. else
  61. {
  62. // 1-ms object test time so that all write threads have a chance to access
  63. // resources... this delay must be viewed "as other work done by thread"
  64. while (WaitForSingleObject(m_hShutdownEvent, 20) != WAIT_OBJECT_0)
  65. {
  66. // Writer thread functionality
  67. m_pcLock->lockWrite();
  69. g_nWriteLockAccesses++;
  71. memset(g_szStringToUpdate, 0, strlen(g_szStringToUpdate));
  72. // copy writer message to global string
  73. strcpy(g_szStringToUpdate, szWriterMessage);
  75. m_pcLock->unlockWrite();
  76. }
  77. }
  78. }