作者topwing (Levin)
看板C_and_CPP
标题[问题] SetEvent无法再次呼叫thread
时间Wed Dec 9 21:47:09 2009
这支程式是这样的
在回圈前分别产生WakeEvent_1&WakeEvent_2与ThreadOne&ThreadTwo
并且在两个Thread里面用WaitForSingleObject(WakeEvent, INFINITE)来等待
之後进入回圈,在回圈内分别随机产生5个数字至in_1和in_2这两个阵列
之後再用SetEvent(WakeEvent)来提醒Thread,之後显示完再用ResetEvent(WakeEvent)
来重置,回圈内就做五遍这样的动作
但问题来了,在刚进入回圈时SetEvent还能够提醒两个Thread,之後就完全进不去Thread...
麻烦指教一下,感谢!
以下是code
/* AES Encryption System*/
#include <stdio.h>
#include <stdlib.h>
#include <time.h>
#include <windows.h>
#define SIZE 5 //资料数
int n_1[SIZE];
int n_2[SIZE];
void ThreadOne(LPVOID params_1);//thread1
void ThreadTwo(LPVOID params_2);//thread2
int bubble(int n[])//bubble sort
{
int temp,i,j;
for(j=0;j<SIZE;j++)
for(i=0;i<SIZE-j-1;i++)
if(n[i]>n[i+1]) {
temp = n[i];
n[i] = n[i+1];
n[i+1] = temp;
}
return 0;
}
int main() {
//thread
HANDLE hThread_1;
HANDLE hThread_2;
HANDLE WakeEvent_1 = CreateEvent(NULL, TRUE, FALSE, NULL);
HANDLE WakeEvent_2 = CreateEvent(NULL, TRUE, FALSE, NULL);
DWORD threadId;
int count=1,i;
srand(time(NULL));
hThread_1 =
CreateThread(NULL,0,(LPTHREAD_START_ROUTINE)ThreadOne,WakeEvent_1,0,&threadId);
hThread_2 =
CreateThread(NULL,0,(LPTHREAD_START_ROUTINE)ThreadTwo,WakeEvent_2,0,&threadId);
for(count = 1; count <= 5; count++) {
//区块1
for(i=0;i<SIZE;i++)
n_1[i] = rand()%100;
//printf("呼叫SetEvent(WakeEvent_1);\n");
SetEvent(WakeEvent_1);
//区块2
for(i=0;i<SIZE;i++)
n_2[i] = rand()%100;
//printf("呼叫SetEvent(WakeEvent_2);\n");
SetEvent(WakeEvent_2);
printf("count = %d\n",count);
WaitForSingleObject(hThread_1, INFINITE);
for(i = 0; i < SIZE; i++)
printf("n_1[%d]=%d\n",i,n_1[i]);
ResetEvent(WakeEvent_1);
WaitForSingleObject(hThread_2, INFINITE);
for(i = 0; i < SIZE; i++)
printf("n_2[%d]=%d\n",i,n_2[i]);
ResetEvent(WakeEvent_2);
}//for(count = 1; count < 5; count++) end
//close handles
CloseHandle(hThread_1);
//close handles
CloseHandle(hThread_2);
system("pause");
}
void ThreadOne(LPVOID params_1)//thread1
{
printf("已经进入ThreadOne\n");
HANDLE WakeEvent_1 = (HANDLE)params_1;
DWORD rc = WaitForSingleObject(WakeEvent_1, INFINITE);
switch (rc) {
case WAIT_OBJECT_0:
// wakeEvent signaled
//printf("已经进入ThreadOne WAIT_OBJECT_0\n");
bubble(n_1);//bubble sort
break;
case WAIT_TIMEOUT:
//printf("已经进入ThreadOne WAIT_TIMEOUT\n");
break;
case WAIT_ABANDONED:;
// main thread ended
//printf("已经进入ThreadOne WAIT_ABANDONED\n");
}
}
void ThreadTwo(LPVOID params_2)//thread2
{
printf("已经进入ThreadTwo\n");
HANDLE WakeEvent_2 = (HANDLE)params_2;
DWORD rc = WaitForSingleObject(WakeEvent_2, INFINITE);
switch (rc) {
case WAIT_OBJECT_0:
// wakeEvent signaled
//printf("已经进入ThreadTwo WAIT_OBJECT_0\n");
bubble(n_2);//bubble sort
break;
case WAIT_TIMEOUT:
//printf("已经进入ThreadTwo WAIT_TIMEOUT\n");
break;
case WAIT_ABANDONED:;
// main thread ended
//printf("已经进入ThreadTwo WAIT_ABANDONED\n");
}
}
--
※ 发信站: 批踢踢实业坊(ptt.cc)
◆ From: 118.169.103.101