Chapter4程序的并发执行..docVIP

第四章 多线程编程 （3学时） 一、为什么需要？ 考虑一下我们的网络程序，比如说上次作业的聊天室的客户端：一方面，客户需要调用recv()或者recvfrom()来接收服务器给它发送的消息；一方面，客户还要接受用户键盘的输入，比如说，gets()或者scanf()。 有什么问题？不管是recv()还是gets()，都是阻塞调用的，如果程序是顺序执行的话，会阻塞在这两个地方之一，结果是，客户端在等待用户输入的时候就不能接收服务器发送过来的数据，在等待接收服务器数据的时候就不能接受用户的输入。问题是，两方面的输入都是不可预期的，你怎么来设计函数的执行次序呢？比如说，现在，你是想先等待用户的输入还是先等待接收服务器的数据呢？ 大家见过这样憋足的客户端软件吗？ 解决方案——多线程 线程是CPU调度的基本单位。 一般，线程具有就绪、阻塞和运行三种基本状态线程可以创建和撤消，从而实现程序的并发执行。从逻辑角度来看，多线程的意义在于一个应用程序中，有多个执行部分可以同时执行共享相同的内存地址空间这就意味着它们可以访问相同的变量和对象，而且它们从同一堆中分配对象 void( __cdecl *start_address )( void * ), //新线程所要执行函数的起始地址 unsigned stack_size, //栈的大小，可以设置为0 void *arglist //参数列表 ); 返回值：正确——新线程的句柄；错误——返回-1 __cdecl：调用约定，类似的有：__stdcall、__fastcall VC下编写多线程程序除了包含头文件 #include process.h 一定要记住如下的设定，不然编译会出错的： Project-Settings-C/C++-Category：Code Generation，Use run-time library：Multithreaded //thread.cpp #pragma comment(lib, ws2_32.lib) #include stdio.h #include process.h #include winsock2.h #define MAX_THREAD_NUM 3 WSAEVENT evFin[MAX_THREAD_NUM]; void __cdecl WorkerThread(void * param) { int data = (int)param; printf(\n0x%x, data=0x%x, data=%d\n, GetCurrentThreadId(), data, data); for (int i=0; i100; i++) { printf(%d, data); //VOID Sleep( DWORD dwMilliseconds ); Sleep(1000); //Sleep(rand()); } printf(\nThread[%d] exit...\n, data); WSASetEvent(evFin[data]); } int main() { for (int i=0; iMAX_THREAD_NUM; i++) { evFin[i] = WSACreateEvent(); } for(i=0; iMAX_THREAD_NUM; i++) { _beginthread(WorkerThread, 0, (void *)i); // _beginthread(WorkerThread, 0, (void *)i); //多个线程都从同一个地址读入相同的数值 } WSAWaitForMultipleEvents(MAX_THREAD_NUM, evFin, TRUE, WSA_INFINITE, false); for(i=0; iMAX_THREAD_NUM; i++) { WSACloseEvent(evFin[i]); } return 0; } 运行结果： 0x98c, data=0x52ff78, data=0 0xe64, data=0x72ff78, data=2 0xc78, data=0x62ff78, data=1 10210212012012012001201201201201212012012012001201201201201212012012012001201201 20120121201201201200120120120120121201201201200120120120120121201201201200120120 12012012120120120120012012012012012120120120