Далее в классе CursorWin объявляются три функции потока мыши:
• MouseThread()
• UpdateCursorSimpleCase()
• UpdateCursorComplexCase()
Функция MouseThread() реализует поток ввода. Когда основной поток создает поток ввода, он передает указатель на статическую функцию MouseThread(). Созданный поток использует эту функцию в качестве точки входа и продолжает выполнять ее до возврата из функции или вызова функции AfxEndThread(). Функция MouseThread() обновляет изображение курсора с помощью функций UpdateCursorSimpleCase() и UpdateCursorComplexCase().
В оставшейся части класса CursorWin объявляются две группы переменных. Первая группа относится к работе с мышью. Все эти переменные объявлены статическими, чтобы статическая функция MouseThread() могла к ним обратиться (а также потому, что доступ к статическим переменным осуществляется чуть быстрее).
Обратите внимание: в число переменных мыши входят объекты классов CCriticalSection, CEvent и CWinThread, предназначенные для синхронизации двух потоков нашей программы.
Мы объявляем два указателя на объекты CEvent — один используется для оповещений DirectInput, а второй сигнализирует о завершении потока.
Вторая группа переменных не относится к работе с мышью. В нее входит массив указателей на интерфейсы DirectDrawSurface, через которые мы обращаемся к отдельным кадрам анимации спирали.
Инициализация приложения
Наше знакомство с программой Cursor начинается с функции OnCreate(), которая отвечает за инициализацию DirectDraw, DirectInput и потока ввода. Функция OnCreate() приведена в листинге 7.2.
Листинг 7.2. Функция CursorWin::OnCreate()
int CursorWin::OnCreate(LPCREATESTRUCT lpCreateStruct) {
HRESULT r=DirectInputCreate(AfxGetInstanceHandle(), DIRECTINPUT_VERSION, &dinput, 0);
if (r!=DI_OK) {
AfxMessageBox("DirectInputCreate() failed");
return -1;
}
if (InitMouse()==FALSE) return -1;
if (InitKeyboard()==FALSE) return -1;
if (DirectDrawWin::OnCreate(lpCreateStruct) == -1) return -1;
mousethread->ResumeThread();
return 0;
}
Сначала OnCreate() инициализирует DirectInput функцией DirectInputCreate(). Затем мышь и клавиатура инициализируются функциями InitMouse() и InitKeyboard(), после чего вызывается функция DirectDrawWin::OnCreate(). Функция InitMouse(), которую мы рассмотрим чуть ниже, создает поток ввода, доступ к которому осуществляется через указатель mousepointer. Однако поток ввода создается в приостановленном состоянии, чтобы он не пытался преждевременно обращаться к первичной поверхности. Поток будет запущен лишь после инициализации DirectDraw. Приостановленный поток активизируется функцией CWinThread::ResumeThread().
Давайте рассмотрим функцию InitMouse(), чтобы получить общее представление об инициализации мыши и создании потока ввода. Функция InitMouse() приведена в листинге 7.3.
Листинг 7.3. Функция InitMouse()
BOOL CursorWin::InitMouse() {
HRESULT r;
r = dinput->CreateDevice(GUID_SysMouse, &mouse, 0);
if (r!=DI_OK) {
TRACE("CreateDevice(mouse) failedn");
return FALSE;
}
r = mouse->SetDataFormat(&c_dfDIMouse);
if (r!=DI_OK) {
TRACE("mouse->SetDataFormat() failedn");
return FALSE;
}
r = mouse->SetCooperativeLevel(GetSafeHwnd(), DISCL_NONEXCLUSIVE | DISCL_FOREGROUND);
if (r!=DI_OK) {
TRACE("mouse->SetCooperativeLevel() failedn");
return FALSE;
}
DIPROPDWORD property;
property.diph.dwSize=sizeof(DIPROPDWORD);
property.diph.dwHeaderSize=sizeof(DIPROPHEADER);
property.diph.dwObj=0;
property.diph.dwHow=DIPH_DEVICE;
property.dwData=64;
r = mouse->SetProperty(DIPROP_BUFFERSIZE, &property.diph);
if (r!=DI_OK) {
TRACE("mouse->SetProperty() failed (buffersize)n");
return FALSE;
}
mouse_event[mouse_event_index]=new CEvent;
mouse_event[quit_event_index]=new CEvent;
r = mouse->SetEventNotification(*mouse_event[mouse_event_index]);
if (r!=DI_OK) {
TRACE("mouse->SetEventNotification() failedn");
return FALSE;
}
mousethread=AfxBeginThread((AFX_THREADPROC)MouseThread, this, THREAD_PRIORITY_TIME_CRITICAL, 0, CREATE_SUSPENDED);
return TRUE;
}
Функция InitMouse() состоит из семи этапов:
1. Инициализация устройства DirectInput, которое представляет мышь.
2. Выбор формата данных, получаемых от мыши.
3. Установка уровня кооперации для мыши.
4. Инициализация буфера данных мыши.
5. Создание двух объектов CEvent.
6. Инициализация механизма оповещений DirectInput.
7. Создание потока ввода.
На этапах 1-4 происходит нормальная инициализация DirectInput, подробно рассмотренная в главе 6, поэтому основное внимание будет уделено этапам 5, 6 и 7.
На этапе 5 создаются два динамических объекта CEvent, а полученные указатели сохраняются в маленьком массиве. Положение этих указателей в массиве определяется константами mouse_event_index и quit_event_index (которые равны 0 и 1 соответственно). Первое событие блокирует или активизирует поток ввода в зависимости от того, поступили ли от мыши новые данные. Второе событие сообщает потоку мыши о завершении приложения. Как мы вскоре увидим, указатели сохраняются в массиве для того, чтобы мы могли заблокировать поток мыши по двум событиям одновременно.
На этапе 6 функция SetEventNotification() интерфейса DirectInputDevice приказывает DirectInput устанавливать событие мыши при появлении новых данных. Функция SetEventNotification() получает один аргумент типа HANDLE, однако наш объект CEvent наследует оператор преобразования типа от класса CSyncObject, благодаря чему мы можем использовать объект CEvent так, словно он имеет тип HANDLE (тип HANDLE, в частности, используется потоковым API Win32 для представления событий).
На этапе 7 создается поток ввода от мыши. Я снова приведу соответствующий фрагмент листинга 7.2:
mousethread=AfxBeginThread((AFX_THREADPROC)MouseThread, this, THREAD_PRIORITY_TIME_CRITICAL, 0, CREATE_SUSPENDED);
Существуют и другие способы создания потоков, но функция AfxBeginThread() является самым простым вариантом. Она получает шесть аргументов, однако последние четыре имеют значения по умолчанию, так что обязательными являются лишь два аргумента. В нашем случае передается пять аргументов.
Первый аргумент AfxBeginThread — указатель на функцию, выполняемую новым потоком; в нашем случае используется функция MouseThread(). Второй аргумент — значение, которое передается функции потока при вызове. Мы передаем указатель this, чтобы функция MouseThread() могла обращаться к членам нашего класса.
Третий аргумент — приоритет потока. По умолчанию для потока устанавливается нормальный приоритет (флаг THREAD_PRIORITY_NORMAL), но мы переопределяем его и задаем флаг THREAD_PRIORITY_TIME_CRITICAL, чтобы добиться наискорейшего отклика курсора.
Четвертый аргумент — размер стека для нового потока. Ноль означает, что размер стека выбирается по умолчанию. Пятый и последний аргумент определяет исходное состояние потока. Если он равен нулю, создается активный поток; в нашем случае использован флаг CREATE_SUSPENDED, чтобы создавался приостановленный поток.
На создании потока ввода работа функции InitMouse() заканчивается. Благодаря флагу CREATE_SUSPENDED поток ввода приостанавливается до момента, когда основной поток завершит инициализацию DirectDraw. Затем, перед возвратом из функции OnCreate(), поток ввода активизируется функцией ResumeThread() (см. листинг 7.2).
Функция DrawScene()
Функция DrawScene() отвечает за подготовку нового кадра во вторичном буфере, обновление курсора и переключение страниц. Функция DrawScene() выполняется в основном потоке, поэтому она должна синхронизировать доступ к первичной поверхности и очереди событий мыши с потоком ввода. Функция DrawScene() приведена в листинге 7.4.
Листинг 7.4. Функция DrawScene()
void CursorWin::DrawScene() {
//------ Проверить клавишу ESCAPE -------
static char key[256];
keyboard->GetDeviceState(sizeof(key), &key);
if (key[DIK_ESCAPE] & 0x80) PostMessage(WM_CLOSE);
//------ Обычные задачи ------
ClearSurface(backsurf, 0);
BltSurface(backsurf, dm_surf, 539, 0);
static coil_idx;
BltSurface(backsurf, coil[coil_idx], coilx, coily);
coil_idx=(coil_idx+1)%coil_frames;
//------ Начало синхронизированной секции ------
critsection.Lock();
//------ Сохранить область вторичного буфера под курсором
RECT src;
src.left=curx;
src.top=cury;
src.right=curx+cursor_width;
src.bottom=cury+cursor_height;
cursor_under->BltFast(0, 0, backsurf, &src, DDBLTFAST_WAIT);
//------ Нарисовать курсор во вторичном буфере
backsurf->BltFast(curx, cury, cursor, 0, DDBLTFAST_SRCCOLORKEY | DDBLTFAST_WAIT);
