#include "igs_resource_thread.h"
#include "igs_resource_multithread.h"

namespace
{
#if defined _WIN32 // vc compile_type
unsigned __stdcall
#else
void *
#endif
	function_(void *param)
{
	igs::resource::thread_execute_interface *pp =
		static_cast<
			igs::resource::thread_execute_interface *>(param);
	pp->run();
	return 0;
};
}

void igs::resource::multithread::add(void *thread_execute_instance)
{
	this->thre_exec_.push_back(thread_execute_instance);
}

void igs::resource::multithread::run(void)
{
	if (1 == this->thre_exec_.size()) {
		/* 指定が一個の場合はスレッド実行せず、ただ実行 */
		igs::resource::thread_execute_interface *pp =
			static_cast<
				igs::resource::thread_execute_interface *>(
				this->thre_exec_.at(0));
		pp->run();
		return;
	}

// pthread_t = unsigned long int(rhel4)
// HANDLE = unsigned long(vc6.0) = void *(vc2005)
#if defined _WIN32 // vc compile_type
	std::vector<HANDLE> id;
#else
	std::vector<pthread_t> id;
#endif
	{
		std::vector<void *>::iterator it;
		for (it = this->thre_exec_.begin();
			 it != this->thre_exec_.end(); ++it) {
			id.push_back(igs::resource::thread_run(function_, *it));
		}
	}
	{
#if defined _WIN32 // vc compile_type
		std::vector<HANDLE>::iterator it;
#else
		std::vector<pthread_t>::iterator it;
#endif
		for (it = id.begin(); it != id.end(); ++it) {
			igs::resource::thread_join(*it);
		}
	}

	id.clear();
}
void igs::resource::multithread::clear(void)
{
	this->thre_exec_.clear();
}