#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();

}