#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);</igs::resource::thread_execute_interface>

  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 *="">(</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;</handle>

#else

  std::vector<pthread_t> id;</pthread_t>

#endif

  {

    std::vector<void *="">::iterator it;</void>

    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;</handle>

#else

    std::vector<pthread_t>::iterator it;</pthread_t>

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