C语言实现的多线程小程序

#include "msg_queue.h" #include "demo_thread.h" int main() { int wait_flag; msg_ptr p; HANDLE h_app_thread1,h_app_thread2,h_kernel_thread; DWORD app_thread1_id,app_thread2_id,kernel_thread_id; msg_queue app_queue,kernel_queue; printf("start!\n"); printf("initial app msg queue...\n"); init_msg_queue(&app_queue); printf("initial kernel msg queue...\n"); init_msg_queue(&kernel_queue); //create threads printf("start threads...\n"); h_app_thread1=CreateThread(NULL,0,(LPTHREAD_START_ROUTINE)app_thread1_func,&app_queue,0,&app_thread1_id); h_app_thread2=CreateThread(NULL,0,(LPTHREAD_START_ROUTINE)app_thread2_func,&app_queue,0,&app_thread2_id); h_kernel_thread=CreateThread(NULL,0,(LPTHREAD_START_ROUTINE)kernel_thread_func,&kernel_queue,0,&kernel_thread_id); printf("thread1_id:%ld,thread2_id:%ld,thread3_id:%ld\n",app_thread1_id,app_thread2_id,kernel_thread_id); app_msg_mutex=CreateMutex(NULL,FALSE,NULL); while(1) { Sleep(1000);wait_flag=0; while(is_empty_msg_queue(app_queue) && is_empty_msg_queue(kernel_queue)){ if(!wait_flag){ printf("waiting...");wait_flag=1;} else printf("."); Sleep(100); } if(msg_dequeue(&app_queue,&p)){ printf("\napp_dequeue:%s\n",p->msg_dat); free(p); } if(msg_dequeue(&kernel_queue,&p)){ printf("kernel_dequeue:%s\n",p->msg_dat); free(p); } } CloseHandle(app_msg_mutex); TerminateThread(h_app_thread1,0); TerminateThread(h_app_thread2,0); TerminateThread(h_kernel_thread,0); return 0; }