スレッドセーフになっていない

Question

スレッドセーフなログクラスを作成しているのですが、スレッドセーフになっていない気がします。
以下のコードを実行したとき、テキストファイルに書かれるのは30行だと思うのですが、結果はそれより少ない行数になったりします。
どこが間違っているのかわからないでいます。アドバイスいただきたいです。

Log.h

#include <string>
#include <mutex>

class Log
{
public:
	static Log &GetInstance(
		const std::wstring path,
		const std::wstring filename
	);

	void OutFile(
		const std::wstring msg
	);

private:
	Log(
		const std::wstring path,
		const std::wstring filename
	);
	~Log() {};
	Log(const Log &other) {};
	Log& operator=(const Log &other) {};

private:
	std::mutex m_mtx;
	std::wstring m_file_location;

};

Log.cpp

#include "Log.h"
#include <fstream>

Log &Log::GetInstance(
	const std::wstring path,
	const std::wstring name
) {
	static Log instance(path, name);
	return instance;
}

Log::Log(
	const std::wstring path,
	const std::wstring name
) {
	m_file_location = path;
	m_file_location += name;
}

void Log::OutFile(
	const std::wstring msg
) {
	std::unique_lock<std::recursive_mutex>(m_mtx);
	std::wofstream wfs; // wstring用filestreamの型
	wfs.open(m_file_location, std::ios::app);
	wfs << msg << std::endl;
}

main.cpp

#include "log.h"
#include <thread>


int main() {
	const std::wstring path = L".\";
	const std::wstring name = L"test.txt";

	static Log &log = Log::GetInstance(path, name);

	std::thread t1([&](){ for (int i=0;i<10;i++) log.OutFile(L"Hello thread1!"); });
	std::thread t2([&](){ for (int i=0;i<10;i++) log.OutFile(L"Hello thread2!"); });
	std::thread t3([&](){ for (int i=0;i<10;i++) log.OutFile(L"Hello thread3!"); });

	t1.join();
	t2.join();
	t3.join();

	return 0;
}

Comments

[fukatani]

よさそうにも見えますが、、
出力も貼っていただけないでしょうか？

Answer 1

std::unique_lock<std::recursive_mutex>(m_mtx);

これだとunique_lockの生存期間はこの式のみですから、生成して即座に破棄され、後続の行はスレッドセーフではありません。
ちゃんと名前を付けて変数にしてやれば、ブロックスコープになるので、ブロックを抜けるまでの間ロックされます。

std::unique_lock<std::recursive_mutex> lock(m_mtx);  // 名前をつけてやる
std::wofstream wfs; // wstring用filestreamの型
wfs.open(m_file_location, std::ios::app);
wfs << msg << std::endl;

Comments

[ddd8]

なるほど…
すみません。ありがとうございます！