68 lines
1.4 KiB
C++
68 lines
1.4 KiB
C++
#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();
|
|
}
|