「マルチスレッドの制御」の編集履歴（バックアップ）一覧はこちら

マルチスレッドの制御 - (2006/01/29 (日) 00:51:52) の１つ前との変更点

追加された行は緑色になります。

削除された行は赤色になります。

*ここでは、VC++のMFCを使用したマルチスレッドの制御について記述します。

*開発環境：
 WindowsXP Pro SP2
 VC++ 6.0

*使用する関数：
・AfxBeginThread();
・ResumeThread();
・TerminateThread();
・WaitForSingleObject();

*サンプルコード：
Javaのように簡単にスレッドを実装できるラッパークラス。
デザインパターンにCommandを使用。

CRunnableインターフェースを実装したクラスAを作成し、
インスタンスのポインタをCJThreadのコンストラクタに渡す。

CJThreadのインスタンスのStart()を呼ぶとCRunnableの実装クラスで
オーバーライドしたRun()がスレッド上で処理される。

[JThread.h]
#ifndef __JTHREAD_H__
#define __JTHREAD_H__


// JThread のインターフェース
// スレッドを実行させたいクラスに継承させて、Run() をオーバーライドする
class CRunnable  
{
public:
  CRunnable(){;}
  virtual ~CRunnable(){;}
  virtual UINT Run() = 0;
};


class CJThread : public CRunnable
{
public:
  CJThread(CRunnable* pRunnable){
    m_pRunnable = pRunnable;
    m_hThread   = NULL;
    m_iRet      = 0;
    m_fEnd      = FALSE;
  }
  virtual ~CJThread();

  HANDLE Start(int nPriority = THREAD_PRIORITY_NORMAL);
  HANDLE Suspend(int nPriority = THREAD_PRIORITY_NORMAL);
  DWORD  Resume();
  void   Stop();
  BOOL   Wait();

  BOOL   GetReturnValue(UINT &iRet);

private:
  CJThread();

  HANDLE      ThreadStart(BOOL fSuspend, int nPriority);
  UINT        ThreadProc();
  static UINT ThreadEntry(PVOID pParam);

  CRunnable*  m_pRunnable;
  HANDLE      m_hThread;
  UINT        m_iRet;
  BOOL        m_fEnd;
};

#endif // #ifndef __JTHREAD_H__

/*****************************************************/
[JThread.cpp]
#include "stdafx.h"
#include "JThread.h"

#define THREAD_STOP 0

CJThread::CJThread()
{
  m_pRunnable = NULL;
  m_hThread   = NULL;
  m_iRet      = 0;
  m_fEnd      = FALSE;
}

CJThread::~CJThread()
{

}

HANDLE CJThread::ThreadStart(BOOL fSuspend, int nPriority)
{
  CWinThread* pThread = NULL;
  DWORD       dwCreateFlags = 0; 

  if(fSuspend){
    dwCreateFlags = CREATE_SUSPENDED;
  }

  pThread = AfxBeginThread(ThreadEntry, this, nPriority, 0, dwCreateFlags);
  if (pThread != NULL) {
    m_hThread = pThread->m_hThread;
  }

  return m_hThread;
}

UINT CJThread::ThreadEntry(PVOID pParam)
{
  return static_cast<CJThread*>(pParam)->ThreadProc();
}

UINT CJThread::ThreadProc()
{
  m_iRet = m_pRunnable->Run();
  m_fEnd = TRUE;

  return m_iRet;
}

HANDLE CJThread::Start(int nPriority)
{
  m_fEnd = FALSE;
  return ThreadStart(FALSE, nPriority);
}

HANDLE CJThread::Suspend(int nPriority)
{
  m_fEnd = FALSE;
  return ThreadStart(TRUE, nPriority);
}

DWORD CJThread::Resume()
{
  DWORD dwRet = -1;

  if(m_hThread != NULL){
    dwRet = ResumeThread(m_hThread);
  }

  return dwRet;
}

void CJThread::Stop()
{
  if(m_hThread != NULL){
    TerminateThread(m_hThread, THREAD_STOP);
  }

  m_fEnd = TRUE;
}

BOOL CJThread::GetReturnValue(UINT &iRet)
{
  if(!m_fEnd){
    return FALSE;
  }else{
    iRet = m_iRet;
    return TRUE;
  }
}

BOOL CJThread::Wait()
{
  BOOL  bRet  = TRUE;
  DWORD dwRet = 0;

  if(m_hThread != NULL){
    dwRet = WaitForSingleObject(m_hThread, INFINITE);
    if(dwRet==WAIT_FAILED){
      bRet = FALSE;
    }
  }else{
    bRet = FALSE;
  }
  
  return bRet;
}
/*****************************************************/

*TIPS:
AfxBeginThread()の引数について。
  CWinThread* AfxBeginThread(
    AFX_THREADPROC pfnThreadProc,
    LPVOID pParam,
    int nPriority = THREAD_PRIORITY_NORMAL,
    UINT nStackSize = 0,
    DWORD dwCreateFlags = 0,
    LPSECURITY_ATTRIBUTES lpSecurityAttrs = NULL );


制御関数のアドレス
制御関数に渡すパラメータ
(省略可) 優先順位。デフォルトの優先順位は normal 
(省略可) スレッドのスタック サイズ
(省略可) スレッド作成時に一時停止状態にしたい時に CREATE_SUSPENDED を渡す
(省略可) セキュリティ属性。デフォルトでは親スレッドと同じ値。