牵着老婆满街逛

严以律己,宽以待人. 三思而后行.
GMail/GTalk: yanglinbo#google.com;
MSN/Email: tx7do#yahoo.com.cn;
QQ: 3 0 3 3 9 6 9 2 0 .

内核式线程同步之waitable timer

转载自:http://zouxiaochuan.bokee.com/3227203.html

waitable timer
      
顾名思义,就是隔一段时间被signaled的一种内核对象。waitable timer跟event对象一样可以在创建的时候指定reset方式,如果是manual-reset,那么当waitable timer对象被signaled时,所有等待这个对象的wait函数都会返回。如果是auto-reset那么就只有一个wait函数会返回。

创建完waitable timer对象后,必须通过SetWaitableTimer函数对它进行时间上的设置。时间格式是个问题,看下面代码

// Declare our local variables.
HANDLE hTimer;
SYSTEMTIME st;
FILETIME ftLocal, ftUTC;
LARGE_INTEGER liUTC;

// Create an auto-reset timer.
hTimer = CreateWaitableTimer(NULL, FALSE, NULL);

// First signaling is at January 1, 2002, at 1:00 P.M. (local time).
st.wYear         = 2002// Year
st.wMonth        = 1;    // January
st.wDayOfWeek    = 0;    // Ignored
st.wDay          = 1;    // The first of the month
st.wHour         = 13;   // 1PM
st.wMinute       = 0;    // 0 minutes into the hour
st.wSecond       = 0;    // 0 seconds into the minute
st.wMilliseconds = 0;    // 0 milliseconds into the second

SystemTimeToFileTime(
&st, &ftLocal);

// Convert local time to UTC time.
LocalFileTimeToFileTime(&ftLocal, &ftUTC);
// Convert FILETIME to LARGE_INTEGER because of different alignment.
liUTC.LowPart  = ftUTC.dwLowDateTime;
liUTC.HighPart 
= ftUTC.dwHighDateTime;

// Set the timer.
SetWaitableTimer(hTimer, &liUTC, 6 * 60 * 60 * 1000, NULL, NULL, FALSE);

 

上面的代码查下MSDN应该很容易理解,这里要说的是CPU对齐的问题。FILETIME结构必须位于32位边界,而LARGE_INTEGER必须位于64位边界,所以不能将FILETIME直接传给SetWaitableTimer。

SetWaitableTimer也可以使用时间的绝对值,或者使用相对时间值。不过这时的值必须是负的。看下面代码:

// Declare our local variables.
HANDLE hTimer;
LARGE_INTEGER li;

// Create an auto-reset timer.
hTimer = CreateWaitableTimer(NULL, FALSE, NULL);

// Set the timer to go off 5 seconds after calling SetWaitableTimer.
// Timer unit is 100-nanoseconds.
const int nTimerUnitsPerSecond = 10000000;

// Negate the time so that SetWaitableTimer knows we 
// want relative time instead of absolute time.
// This indicate that the timer will be signaled 5 seconds after the call to SetWaitableTimer
li.QuadPart = -(5 * nTimerUnitsPerSecond); 
 
// Set the timer.
SetWaitableTimer(hTimer, &li, 6 * 60 * 60 * 1000, NULL, NULL, FALSE);

清除waitable timer对象需要用到CancelWaitableTimer函数。

特别提出的是waitable timer这节引出了一个新概念:APC(asynchronous procedure call)。按照我的理解,APC应该是线程特有的一个队列,里面装的是函数地址。如果一个函数地址被装入APC,如果这时线程处于待命的等待状态(alertable wait),那么这个线程就会被唤醒去调用APC里的函数;否则,APC里的函数地址就会被忽略掉。这里的这个线程指的是调用SetWaitableTimer的线程。下面的代码能说明问题

VOID APIENTRY TimerAPCRoutine(PVOID pvArgToCompletionRoutine,
   DWORD dwTimerLowValue, DWORD dwTimerHighValue) 
{

   FILETIME ftUTC, ftLocal;
   SYSTEMTIME st;
   TCHAR szBuf[
256];

   
// Put the time in a FILETIME structure.
   ftUTC.dwLowDateTime = dwTimerLowValue;
   ftUTC.dwHighDateTime 
= dwTimerHighValue;

   
// Convert the UTC time to the user's local time.
   FileTimeToLocalFileTime(&ftUTC, &ftLocal);

   
// Convert the FILETIME to the SYSTEMTIME structure
   
// required by GetDateFormat and GetTimeFormat.
   FileTimeToSystemTime(&ftLocal, &st);

   
// Construct a string with the 
   
// date/time that the timer went off.
   GetDateFormat(LOCALE_USER_DEFAULT, DATE_LONGDATE, 
      
&st, NULL, szBuf, sizeof(szBuf) / sizeof(TCHAR));
   _tcscat(szBuf, _ _TEXT(
" "));
   GetTimeFormat(LOCALE_USER_DEFAULT, 
0,
      
&st, NULL, _tcschr(szBuf, 0), 
      
sizeof(szBuf) / sizeof(TCHAR) - _tcslen(szBuf));

   
// Show the time to the user.
   MessageBox(NULL, szBuf, "Timer went off at", MB_OK);
}


void SomeFunc() {
   
// Create a timer. (It doesn't matter whether it's manual-reset 
   
// or auto-reset.)
   HANDLE hTimer = CreateWaitableTimer(NULL, TRUE, NULL);

   
// Set timer to go off in 5 seconds.
   LARGE_INTEGER li = 0 };
   SetWaitableTimer(hTimer, 
&li, 5000, TimerAPCRoutine, NULL, FALSE);

   
// Wait in an alertable state for the timer to go off.
   SleepEx(INFINITE, TRUE);

   CloseHandle(hTimer);
}

如果指定了APC,那么就不要等待这个waitable timer对象了,因为APC队列会唤醒线程的,不需要wait函数。

posted on 2011-06-02 17:25 杨粼波 阅读(1109) 评论(0)  编辑 收藏 引用


只有注册用户登录后才能发表评论。
网站导航: 博客园   IT新闻   BlogJava   知识库   博问   管理