70 lines
2.3 KiB
C++
70 lines
2.3 KiB
C++
#include <stdexcept> /* std::domain_error */
|
|
#include "igs_resource_thread.h"
|
|
#include "igs_resource_msg_from_err.h"
|
|
|
|
const HANDLE igs::resource::thread_run(
|
|
unsigned(__stdcall *function)(void *), void *func_arg, const int priority)
|
|
{
|
|
//unsigned thread_addr=0;
|
|
HANDLE thread_id = reinterpret_cast<HANDLE>(::_beginthreadex(
|
|
NULL, 0, function, func_arg, 0, NULL));
|
|
if (0 == thread_id) {
|
|
throw std::domain_error(igs_resource_msg_from_err(
|
|
TEXT("_beginthreadex(-)"), errno));
|
|
}
|
|
/*
|
|
vc2005 MSDN より
|
|
BOOL SetThreadPriority(int nPriority);
|
|
に与える値を優先度の高いものから順に並べます。
|
|
THREAD_PRIORITY_TIME_CRITICAL プロセスにより15 or 31
|
|
THREAD_PRIORITY_HIGHEST 標準より2ポイント高い
|
|
THREAD_PRIORITY_ABOVE_NORMAL 標準より1ポイント高い
|
|
THREAD_PRIORITY_NORMAL -1 標準
|
|
THREAD_PRIORITY_BELOW_NORMAL 標準より1ポイント低い
|
|
THREAD_PRIORITY_LOWEST 標準より2ポイント低い
|
|
THREAD_PRIORITY_IDLE プロセスにより1 or 16
|
|
*/
|
|
if (0 == ::SetThreadPriority(thread_id, priority)) {
|
|
throw std::domain_error(igs_resource_msg_from_err(
|
|
TEXT("SetThreadPriority(-)"), ::GetLastError()));
|
|
}
|
|
return thread_id;
|
|
}
|
|
|
|
/*
|
|
以下の関数でthreadの終了を見るよりも、
|
|
thread内で終了時に終了スイッチを入れる方法で感知する。
|
|
linuxでのやり方にあわせる。2011-03-30
|
|
*/
|
|
const bool igs::resource::thread_was_done(const HANDLE thread_id)
|
|
{
|
|
DWORD exit_code = 0;
|
|
if (0 == ::GetExitCodeThread(thread_id, &exit_code)) {
|
|
throw std::domain_error(igs_resource_msg_from_err(
|
|
"GetExitCodeThread(-)", ::GetLastError()));
|
|
}
|
|
if (exit_code == STILL_ACTIVE) {
|
|
return false;
|
|
}
|
|
return true;
|
|
}
|
|
void igs::resource::thread_join(const HANDLE thread_id)
|
|
{
|
|
thread_wait(thread_id);
|
|
thread_close(thread_id);
|
|
}
|
|
void igs::resource::thread_wait(const HANDLE thread_id)
|
|
{
|
|
/* _endthreadex(-)はスレッドハンドルを閉じない??? */
|
|
if (WAIT_FAILED == ::WaitForSingleObject(thread_id, INFINITE)) {
|
|
throw std::domain_error(igs_resource_msg_from_err(
|
|
TEXT("WaitForSingleObject(-)"), ::GetLastError()));
|
|
}
|
|
}
|
|
void igs::resource::thread_close(const HANDLE thread_id)
|
|
{
|
|
if (0 == ::CloseHandle(thread_id)) {
|
|
throw std::domain_error(igs_resource_msg_from_err(
|
|
TEXT("CloseHandle(-)"), ::GetLastError()));
|
|
}
|
|
}
|