メンバ関数（メソッド）をマルチスレッドにしたい

Question

環境はWinXPでVisual Studio 2005を使用しています。
Ｃ言語で関数をマルチスレッド化するにはこんな感じでＯＫでした。

// マルチスレッド関数
void Thread( void * )
{
}

void MainFunc()
{
　　(HANDLE)_beginthread( Thread, 0, NULL );
}



こんな風にスレッド関数をＣ＋＋のメソッドに変えてうまくいくかと思い

class Test_c {
public:
　　void Thread( void * );
} ;

// マルチスレッド関数
void Test_c::Thread( void * )
{
}

void MainFunc()
{
　　Test_c t t;
　　(HANDLE)_beginthread( t.Thread, 0, NULL );
}

とするとエラーが出てきてしまい、コンパイルが通りませんでした。
Ｃ＋＋のメンバ関数をマルチスレッド関数としたい場合はどの様に書けばよいのでしょうか・・？

machongola · Accepted Answer

　こんにちは。

　メンバ関数からスタティックメンバ関数のアドレスとthisポインタを渡してスレッドを起動するのが手っ取り早いです。
　スレッドに飛び込んだら、其のままパラメータをTest_c*にキャストして、メンバ関数側へ迂回出来ます。
　その他、クリティカルセクション等は、外回りで必要に応じてするか、メンバ関数内でするか等、色々有るのですが・・・。
　アラも有りますが、取り敢えずは参考程度に。

#include<windows.h>
#include<mmsystem.h>
#include<process.h>
#include<stdio.h>

#pragma comment(lib, "winmm.lib")

//クリティカルセクション
class CCS
{
CRITICAL_SECTION cs;
public:
CCS(){::InitializeCriticalSection(&this->cs);}
~CCS(){::DeleteCriticalSection(&this->cs);}

CRITICAL_SECTION* get() const { return (CRITICAL_SECTION*)&this->cs; }
};
//排他クラス
class CLock
{
const CCS& rccs;
public:
CLock(const CCS& r) : rccs(r){::EnterCriticalSection(rccs.get());}
~CLock(){::LeaveCriticalSection(rccs.get());}
};
//テストクラス
class Test_c
{
enum { ThreadCount = 2 };
HANDLEarrhThread[ThreadCount];
CCSccs;
intvalue;
//マルチスレッド関数(計算)メンバ関数へ転送
static void ThreadCalc(void* p)
{
Test_c* pTest = (Test_c*)p;
pTest->calc();
}
//マルチスレッド関数(表示)メンバ関数へ転送
static void ThreadPrint(void* p)
{
Test_c* pTest = (Test_c*)p;
pTest->print();
}
//メンバ関数(計算)
void calc()
{
::printf("%s\n", "計算開始");
const DWORD dwStartTime = ::timeGetTime();
//1秒間計算する
while(::timeGetTime() - dwStartTime <= 1000)
{
CLock lock(this->ccs);
++this->value;
::Sleep(16);
}
::printf("%s\n", "計算終了");
::_endthread();
}
//メンバ関数(表示)
void print()
{
::printf("%s\n", "表示開始");
const DWORD dwStartTime = ::timeGetTime();
//1.5秒間表示する
while(::timeGetTime() - dwStartTime <= 1500)
{
CLock lock(this->ccs);
::printf("%d\n", this->value);
::Sleep(16);
}
::printf("%s\n", "表示終了");
::_endthread();
}
public:
//全てがシグナルになるまで待つ
static void Wait(Test_c& t)
{
while(1)
{
const DWORD dwResult = ::WaitForMultipleObjects(ThreadCount, t.arrhThread, TRUE, INFINITE);
if(dwResult >= WAIT_OBJECT_0 && dwResult <= WAIT_OBJECT_0 + ThreadCount - 1)
break;
}
}
Test_c() : ccs(), value(0)
{
for(int i = 0; i < ThreadCount; ++i)
arrhThread[i] = NULL;
}
void start()
{
this->arrhThread[0] = (HANDLE)::_beginthread(&Test_c::ThreadPrint, 0, this);
this->arrhThread[1] = (HANDLE)::_beginthread(&Test_c::ThreadCalc, 0, this);
}
void close()
{
for(int i = 0; i < ThreadCount; ++i)
{
::CloseHandle(arrhThread[i]);
arrhThread[i] = NULL;
}
}
};
//お試し
int main()
{
TIMECAPS tc = {0};
::timeGetDevCaps(&tc, sizeof(tc));
::timeBeginPeriod(tc.wPeriodMin);
Test_c test;
test.start();
Test_c::Wait(test);
::timeEndPeriod(tc.wPeriodMin);
return 0;
}

Situgyosya · Answer

いろいろやり方がありますが、最も自由度が高く、
一般的なのはスレッド関数にthisを渡す方法ですね。
class FOO{
   void TH_Start(){
        ::AfxBeginThread( ThFunc, this,
            THREAD_PRIORITY_NORMAL, 0, 0, NULL);
   }
   void TH_CallBack(){
　　　// ここが実際のスレッドのメインとなります。
   }
}

スレッド関数は渡されたクラスオブジェクトの
クラスコールバックを呼ぶたけです。何もしません。

UINT ThreadFunc( PVOID p_obj){// thisが渡される
    FOO *p_foo = ( FOO *)p_obj;
    p_foo->TH_CallBack();// クラスコールバックを呼ぶ
   return 0;
}

この方法では、あまり細かいコードを書かなくて済みますし
初心者にも直感的にわかりやすい点がお勧めです。

zwi · Answer

class Test_c {
public:
　　static void Thread( void * );
} ;
とすれば呼び出せます。
ただし、やると分りますが別のワナが・・・。thisが使えません。

メンバ関数（メソッド）をマルチスレッドにしたい

こんにちは。

いろいろやり方がありますが、最も自由度が高く、

class Test_c {

似たような質問が見つかりました

関連するカテゴリからQ&Aを探す

デイリーランキングこのカテゴリの人気デイリーQ&Aランキング

マンスリーランキングこのカテゴリの人気マンスリーQ&Aランキング

　こんにちは。