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

源码开发语言/平台
当前位置：首页 > 源码/资料 > 行业应用 > 金融证券系统 > 查看源码
TSWnd.cpp
资源名称：NetTS.rar　[点击查看]
上传用户：nameszq
上传日期：2014-08-12
资源大小：336k
文件大小：3k
源码类别：

金融证券系统

开发平台：

Visual C++

TSWnd.cpp：源码内容
  1. // TSWnd.cpp: implementation of the CTSWnd class.
  2. //
  3. //////////////////////////////////////////////////////////////////////
  5. #include "stdafx.h"
  6. #include "TSWnd.h"
  7. #include "TSCache.h"
  9. #ifdef _DEBUG
  10. #undef THIS_FILE
  11. static char THIS_FILE[]=__FILE__;
  12. #define new DEBUG_NEW
  13. #endif
  15. //////////////////////////////////////////////////////////////////////
  16. // Construction/Destruction
  17. //////////////////////////////////////////////////////////////////////
  19. CTSWnd & CTSWnd::GetInstance( )
  20. {
  21. static CTSWnd s_wndmsg;
  22. return s_wndmsg;
  23. }
  25. CTSWnd::CTSWnd()
  26. {
  27. CTSWnd::GetInstance().StartDispatchThread();
  28. }
  30. CTSWnd::~CTSWnd()
  31. {
  32. }
  34. int CTSWnd::AddWnd( HWND hWnd, UINT nMsg )
  35. {
  36. CSingleLock lock( &m_mutex, TRUE );
  38. TSWND_MSG wndmsg;
  39. wndmsg.hWnd = hWnd;
  40. wndmsg.nMsg = nMsg;
  41. return m_aWndMsg.Add( wndmsg );
  42. }
  44. void CTSWnd::RemoveWnd( HWND hWnd )
  45. {
  46. CSingleLock lock( &m_mutex, TRUE );
  48. for( int i=m_aWndMsg.GetSize()-1; i>=0; i-- )
  49. {
  50. if( m_aWndMsg.ElementAt(i).hWnd == hWnd )
  51. m_aWndMsg.RemoveAt(i);
  52. }
  53. }
  55. void CTSWnd::SendMessage( WPARAM wParam, LPARAM lParam )
  56. {
  57. CTSWndMsgArray aWndMsgTemp;
  59. {
  60. CSingleLock lock( &m_mutex, TRUE );
  61. aWndMsgTemp.SetSize( m_aWndMsg.GetSize() );
  63. for( int i=0; i<m_aWndMsg.GetSize(); i++ )
  64. aWndMsgTemp.SetAt( i, m_aWndMsg.ElementAt(i) );
  65. }
  67. for( int i=0; i<aWndMsgTemp.GetSize(); i++ )
  68. {
  69. ::SendMessage( aWndMsgTemp.ElementAt(i).hWnd, aWndMsgTemp.ElementAt(i).nMsg,
  70. wParam, lParam );
  71. }
  72. }
  74. BOOL CTSWnd::IsEmpty()
  75. {
  76. CSingleLock lock( &m_mutex, TRUE );
  78. return 0 == m_aWndMsg.GetSize();
  79. }
  81. HANDLE CTSWnd::m_hEventKillDispatchThread = NULL;
  82. HANDLE CTSWnd::m_hEventDispatchThreadKilled = NULL;
  84. // 分发接收数据的线程
  85. UINT TSDispatchThreadMain( LPVOID pParam )
  86. {
  87. while( TRUE )
  88. {
  89. UINT nMsgType = 0;
  90. PRCV_DATA pRCV_DATA = NULL;
  91. if( CTSCache::GetInstance().PopPacket( nMsgType, pRCV_DATA ) )
  92. {
  93. ASSERT( pRCV_DATA && pRCV_DATA->m_pData );
  94. if( pRCV_DATA && pRCV_DATA->m_pData )
  95. CTSWnd::GetInstance().SendMessage( nMsgType, (LPARAM)pRCV_DATA );
  96. CTSCache::GetInstance().FreePacket( pRCV_DATA );
  97. }
  99. Sleep( 1000 );
  101. // User wants to quit program
  102. if(WAIT_OBJECT_0 == WaitForSingleObject(CTSWnd::m_hEventKillDispatchThread,0) )
  103. {
  104. SetEvent(CTSWnd::m_hEventDispatchThreadKilled);
  105. AfxEndThread( 0, TRUE );
  106. return 0;
  107. }
  108. }
  109. }
  111. void CTSWnd::StartDispatchThread( )
  112. {
  113. m_hEventKillDispatchThread = CreateEvent(NULL,FALSE,FALSE,NULL);
  114. m_hEventDispatchThreadKilled = CreateEvent(NULL,FALSE,FALSE,NULL);
  116. AfxBeginThread( TSDispatchThreadMain, NULL, THREAD_PRIORITY_NORMAL );
  117. }
  119. void CTSWnd::StopDispatchThread( )
  120. {
  121. /* Do not call this function. it does not work well. */
  122. ASSERT( FALSE );
  123. /*
  124. // These codes do not work well. system will terminate the thread auto, but cause some memory leaks
  125. if( m_hEventKillDispatchThread )
  126. SetEvent(m_hEventKillDispatchThread);
  128. if(WAIT_OBJECT_0 == WaitForSingleObject(m_hEventKillDispatchThread,2000) )
  129. {
  130. if( m_hEventKillDispatchThread )
  131. CloseHandle(m_hEventKillDispatchThread);
  132. if( m_hEventDispatchThreadKilled )
  133. CloseHandle(m_hEventDispatchThreadKilled);
  134. m_hEventKillDispatchThread = NULL;
  135. m_hEventDispatchThreadKilled = NULL;
  136. }
  137. */
  138. }