マルチスレッドでバグが発生します

実際のプログラムでバグが出たので、簡易化したプログラムでテストしてみましたがどこが悪いのか分かりませんでした。

#include <WinSock2.h>
#include <vector>
#include <process.h>
#include <algorithm>
#include <stdio.h>

using namespace std;

CRITICAL_SECTION cs;

unsigned __stdcall Login( void * );

int main()
{
　　　　vector<unsigned int> thID;
　　　　vector<HANDLE> hTh;

　　　　for( int i=0 ; i<10 ; i++ )
　　　　{
　　　　　　　　printf( "メインスレッド：%d\n", i );
　　　　　　　　if( (i%2) == 0 )
　　　　　　　　{
　　　　　　　　　　　　thID.push_back( i );
　　　　　　　　　　　　hTh.push_back( (HANDLE)_beginthreadex(NULL, 0, Login, &i, 0, &thID[i]) );
　　　　　　　　}
　　　　}

　　　　while(1)
　　　　{
　　　　　　　　for( int i=0 ; i<10 ; i++ )
　　　　　　　　{
　　　　　　　　　　　　if( hTh[i] != NULL )
　　　　　　　　　　　　{
　　　　　　　　　　　　　　　　CloseHandle(hTh[i]);
　　　　　　　　　　　　}
　　　　　　　　}

　　　　　　　　char a[2];
　　　　　　　　scanf( "%c", a );
　　　　　　　　if( strcmp( a, "X" ) == 0 )
　　　　　　　　{
　　　　　　　　　　　　return 0;
　　　　　　　　}
　　　　}
}

unsigned __stdcall Login( void *Num )
{
int *a = (int *)Num;
for( int i=0 ; i<10 ; i++ )
{
printf( "サブスレッド%d：%d\n", *a, i );
}
return 0;
}

出るエラーは以下のようになります

Windows によって Server.exe でブレークポイントが発生しました。
ヒープが壊れていることが原因として考えられます。Server.exe または読み込まれた DLL にバグがあります。
あるいは、Server.exe がフォーカスを持っているときに、ユーザーが F12 キーを押したことが原因として考えられます。
可能であれば、出力ウィンドウに詳細な診断情報が表示されます。

if( (i%2) == 0 )
をコメントアウトするとエラーは出ません

また、共に
表示される例として（見やすいように空行あり）
以下のように、
スレッド番号が＋１されていたり（A）
各スレッド内のループ回数が直前のスレッドの回数を引き継いでいたり（B）
スレッドのループ回数が初期化されていたり（C）
呼び出されてないはずのスレッドが起動していたり（D）
します

メインスレッド：０
メインスレッド：１

サブスレッド１：０　・・・・・・A（本来はサブスレッド０のはず）
サブスレッド１：１

メインスレッド：２

サブスレッド２：３　・・・・・・B（本来はサブスレッド２：０のはず）
サブスレッド２：４
サブスレッド２：５

サブスレッド１：０　・・・・・・C（本来は１：３のはず）
サブスレッド１：１

サブスレッド２：０

サブスレッド３：０　・・・・・・D（本来はまだ起動してないはず）
サブスレッド３：１

メインスレッド：３


どこを直せばいいか教えてください

No.4 回答者： episteme 回答日時： 2012/07/01 21:56

> では、どのようにしたらいいのでしょうか？

たとえばこんな:

#include <WinSock2.h>
#include <vector>
#include <tuple>
#include <process.h>
#include <algorithm>
#include <stdio.h>

using namespace std;

CRITICAL_SECTION cs;

unsigned __stdcall Login( void * );

int main() {
typedef tuple<unsigned int, HANDLE, int> record;
vector<record> records;

for( int i=0 ; i<10 ; i++ ) {
printf( "メインスレッド：%d\n", i );
if ( (i%2) == 0 ) {
records.push_back(record());
record& r = records.back();
get<2>(r) = i;
get<1>(r) = (HANDLE)_beginthreadex(NULL, 0, Login, &get<2>(r), 0, &get<0>(r) );
}
}
...

この回答へのお礼

わざわざありがとうございます。
tupleという物があるんですね。
知らなかったです

調べてみましたが、どういうものかは分かりましたがプログラムで何をしているのか分からなかったのでそのままコピペしてみました

結果
メインスレッド：０～９
サブスレッド-17891602：０～９
サブスレッド０：０～９
サブスレッド-17891602：０～９
サブスレッド-17891602：０～９
サブスレッド８：０～９
となりました

大体道筋が見えてきたように思います。

お礼日時：2012/07/01 23:13

No.3 回答者： zwi 回答日時： 2012/07/01 17:14

今現在の問題のあるコードと実行結果を貼って下さい。

この回答への補足

あ、申し訳ありません

前略
{
　　　　vector<unsigned int> thID;
　　　　vector<HANDLE> hTh;
　　　　DWORD dwExCode;

　　　　for( int i=0 ; i<10 ; i++ )
　　　　{
　　　　　　　　printf( "\nメインスレッド：%d\n", i );
　　　　　　　　if( (i%2) == 0 )
　　　　　　　　{
　　　　　　　　　　　　thID.push_back( i );
　　　　　　　　　　　　hTh.push_back( (HANDLE)_beginthreadex(NULL, 0, Login, &i, 0, &thID[i/2]) );
　　　　　　　　}
　　　　}

　　　　while(1)
　　　　{
　　　　　　　　for( int i=0 ; i<hTh.size() ; i++ )
　　　　　　　　{
　　　　　　　　　　　　GetExitCodeThread(hTh[i], &dwExCode);
　　　　　　　　　　　　if( dwExCode != STILL_ACTIVE )
　　　　　　　　　　　　{
　　　　　　　　　　　　　　　　CloseHandle( hTh[i] );

　　　　　　　　　　　　　　　　vector<HANDLE>::iterator end_it = remove( hTh.begin(), hTh.end(), HANDLE(hTh[i]) );
　　　　　　　　　　　　　　　　hTh.erase( end_it, hTh.end() );

　　　　　　　　　　　　　　　　vector<unsigned int>::iterator End_it = remove( thID.begin(), thID.end(), unsigned int(thID[i]) );
　　　　　　　　　　　　　　　　thID.erase( End_it, thID.end() );
　　　　　　　　　　　　}
　　　　　　　　}
　　　　　　　　char a[2];
　　　　　　　　scanf( "%c", a );
　　　　　　　　if( strcmp( a, "X" ) == 0 )
　　　　　　　　{
　　　　　　　　　　　　return 0;
　　　　　　　　}
　　　　}
}
以下略

結果の一例
M：０
M：１
M:2

S2：０
S3：１～９

M：３
M:4

S3：０
S4：１
S5：２～９

M：５
M：６

S5：０
S7：１

M：７
M：８

S7：２
S9：３～９

補足日時：2012/07/01 19:11

No.2 回答者： zwi 回答日時： 2012/07/01 15:52

怪しい所です。

１．スレッドに変数寿命が切れたローカル変数iを渡している。
２．vectorでpush_backした要素数よりも多い番号を参照。
(i%2) == 0 )で２回に一回しかpush_backしないのに&thID[i]でi番目を参照しています。
３．以下の部分は１０個要素がある前提に成っているが１０個無いのでエラーです。
　for( int i=0 ; i<10 ; i++ )
　　　　　　　　{
　　　　　　　　　　　　if( hTh[i] != NULL )
　　　　　　　　　　　　{
　　　　　　　　　　　　　　　　CloseHandle(hTh[i]);
　　　　　　　　　　　　}
　　　　　　　　}
４．スレッドの終了を待たずにCloseHandleしている。

この回答への補足

２．３．４．を直しました
各スレッド内のループ回数が直前のスレッドのループ回数を引き継いでいるのは直りませんでした

補足日時：2012/07/01 17:02

この回答へのお礼

１．はepistemeさんと同じことですよね？
２．３．あ、本当ですね。だから偶数のときにスレッドを立てるようにしたらエラーになったんですね
４．そこは盲点でした。

とりあえず、２．３．４．を直してこようと思います

お礼日時：2012/07/01 16:29

No.1 回答者： episteme 回答日時： 2012/07/01 15:46

　for( int i=0 ; i<10 ; i++ )　{

　　...
　　hTh.push_back( (HANDLE)_beginthreadex(NULL, 0, Login, &i, 0, &thID[i]) );

コロコロ変化している i のポインタを スレッドに引き渡しているのはおかしくない?
スレッドに火が付いた時点で i が変化してるかもですよ?

この回答へのお礼

なるほど。確かにそうですね

では、どのようにしたらいいのでしょうか？

お礼日時：2012/07/01 16:26