マルチスレッドでの関数呼び出し

Question

前提

c++でマルチスレッドアプリケーションを作成しています。
各スレッドは、以下のように処理のWrapperクラスを持っています。

処理クラス（DLLとして実装）

float Proc(float* buf)
{
	float total = 0.f;
	for(int i=0; i<256; i++)
	{
		total += buf[i];
	}
	return total;
}

class Hoge
{
public:
	Hoge();
	float ProcessCall(float* buf);
};
Hoge::Hoge()
{

}

float Hoge::ProcessCall(float* buf)
{
	return Proc(buf);
}

static Hoge s_hoge;

float process(float* buf){return s_hoge.ProcessCall(buf);}

Wrapperクラス

class Wrapper
{
public:
	float Process(float* buf);
};

float Wrapper::Process(float* buf)
{
	return process(buf);
}

呼び出し元（スレッド1）

float Th1()
{
	Wrapper* wr;
	wr = new Wrapper();
	float buf[256];
	for(int i=0; i<256; i++)
	{
		buf[i] = (float)i;
	}
	float ret = wr->Process(buf);

	return ret;
}

呼び出し元（スレッド2）

float Th2()
{
	Wrapper* wr;
	wr = new Wrapper();
	float buf[256];
	for(int i=0; i<256; i++)
	{
		buf[i] = (float)i*2.f;
	}
	float ret = wr->Process(buf);

	return ret;
}

質問

スレッド1がProcess関数を処理中に、スレッド2がProcess関数を呼んだ場合、正しく計算は行われますか？

Comments

[dodox86]

> スレッド1でFuncを呼んでいる間に、スレッド2からFuncが呼ばれると正しく計算されません。

それは本当ですか？　Func()はbuf[0]～[255]の内容を読み出しているだけなので競合しないように見えますが。bufの内容を上書きしている別のスレッドが居るのではないですか？

[tkym_1231]

ご指摘の通り、bufの内容を上書きしている処理がありました。
間違いに合わせて質問内容も修正させていただきました。

[fana]

呼び出し側に関する情報が増えたみたいですが，
Th1() と Th2() とでは全く別のバッファを扱っているわけですから，やはり問題が発生するようには見えません．

[dodox86]

あれれ、確かに、質問内容が変わり、論点が変わったようですね。「提示のコードで正しく動くでしょうか？」と言う質問でしょうか。「処理クラス（DLLとして実装）」でHogeクラスが実装されて、static Hoge s_hoge;と単一のものになっていますが、HogeクラスとWrapperクラスを分ける必要があるのでしょうか。ちょっと見通しが悪いような。（＜個人の意見です）　何となく大丈夫そうにも思えますが、呼び出し側で起動(start)したスレッドをjoinするような部分も見当たりませんし、判断つきかねるところです。実際にスレッドとして起動する際に使うのがstd::threadなのか、pthreadであったりWin32 Threadであったりするのか。

Answer 1

その関数自体の問題ではなく，それを呼んでいる側の問題であろうと思われます．

---

質問が変わったようなので．

スレッド1がProcess関数を処理中に、スレッド2がProcess関数を呼んだ場合、正しく計算は行われますか？

Process関数に渡したバッファが別のスレッドでいじくり回されているような場合には問題があるでしょうけども，
質問に提示されたコードではそのようなことになっていないので，正しい計算が成されるでしょう．