在多线程编程时遇到的问题

1、同学们在多线程编程时遇到的问题整理(1)如何根据文本文件大小，#include <iostream>最后更新时间:2011-12-7 动态创建一个字符数组存放文本文件？#include <fstream> using namespace std;char* textbuf; 定义一*个 char*型指针int main(int argc, char* argv)ifstream infile;int nfilelen;infile.openctext.txt"); 打开一个文件if(!infile) cout«"file open erro

2、r."«endl; infile.seekg(0,ios:end); 把文件读写指针移到文件末尾nfilelen = infile.tellgo; /获取文件长度infile, seekg (0,ios:beg); 把文件读写指针移到文件的起始位置textbuf= new charnfilelen+lj； /根据文件长度，动态申请一块内存，多加一个字节，存 放winfile»textbuf; 把文件内容读入该内存屮cout«texlbuf«endl;return 0;这段代码看似正确，但是，如果文件中有空格和换行，则发现读出的内容仅是文件的一部

3、 分，即从文件第一个字节到文件中第一个空格或换行符出现位置。这是因为 “infile»textbuf;”的特点，它能够读取连续的字符，直至遇到空格或换行符为止。但是文件屮都有空格或换行，怎么才能一次读入所有内容呢？用ainfile.read(textbuf, nfilelen);”代替“infile»textbuf;”。read()方法不区分任何字符的读入内容，最多可读入 变量nfilelen指定的字符数，而且不会在读入字符的末尾自动加，(f,如果你需要把读入内 容变成真正的字符串，需要自己编程在末尾加,w,否则，你不能用”coutvv textbup输出读 入的内容。#i

4、nclude <iostreem#include <fstream>using namespace std;char* textbuf;/定义个char型指针int main(int argc, char* argv)ifstream infile;int nfilelen;infile. open ("text. txt") ;/打开一个文件if (! infile) cout<open error . n<<endl; infile . seekg (oz ios : : end) ;/把文件读写指针移到文件末尾nfilelen =

5、infile . tellg(); /获取文件长度infile . seekg (0, ios : :beg) ;/把文件读写指针移到文件的起始位置textbuf= new char nfilelen + 1 ; /根据文件长度，动态申请一块内存，多加一个 字节，存放infile . read (textbuf z nfilelen) ;/把文i：内容读入该内存中textbufnfilelen = *0'cout<extbuf<<endl;return 0;(2) 如何保证创建的子线程运行完毕后，再在主线程中进行统计工作？ 参考下面“最后更新时间：2011117”的文

6、档。(3) 如何在创建子线程时，给子线程函数传递参数，从而实现不同的线程完 成任务的不同部分？参考下面“最后更新时间：2011109”的文档。同学们在多线程编程时遇到的问题整理最后更新时间：2011-11-7(1)我的程序到底错在哪里?#include hwindows.hu #include nprocess.hn#include <iostream.h># include <stdio.h>handle hmutex;unsigned int _stdcall thread 1 (void* p)int i,j；for(i=0;i<5;i+)waitforsi

7、ngleobject(hmutexjnfinite);for(j=0;j<5;j+) cout«nin threadl.h«endl;releasemutex(hmiitex);return 0;unsigned int _stdcall thread2(void* p)int i,j；for(i=0;i<5;i+)waitforsingleobject(hmutex,infinite);for(j=0;j<5;j+) cout«nin thread2.n«endl;releasemutex(hmutex);return 0;void

8、main(int argc,char* argv)handle hthread2;unsigned threadid2;hmutex=createmutex(null,false,null);cout«ncreating threadl"«endl; hthreado=(handle)_beginthreadex(null,o, thread 1 ,null,0,&threadido);cout«"creating thread2"«endl;hthread 1 =(handle)_beginthreadex(nul

9、l,o, thread2,null,0,&thieadidl);cout«ufinished.nh;closehandle(hthread0);closehtindle(hthread 1 );在主函数屮建立了两个线程，每个线程会输出一些信息，但是运行后，发现运行结果跟预想 的不一样，到底错在哪里？我建立的线程到底运行了没有呢？ ？如果运行了，为什么没有输 出正确的结果呢？ ？如果没运行，到底我的程序错在哪里了呢？ ？(2) 为了验证我的线程是否建立了，我得让程序暂停一下，然后通过任务管理 器查看我的程序中是否生成了两个子线程。于是，我把程序稍微修改一下，在 cout

10、1;nfinished.nn;后面加了一句getchar();让程序停在这里，等待我输入。cout«hfinished.nh;getchar();closehandle(hthread0);closehandle(hthread 1 );再次运行我的程序，发现输出结果竟然变化了！？ ？发现两个子进程中的内容 能够显示了。难道，getcharo®数如此神奇？还是我的程序另有错误？ ？(3) 思考，为什么加上getchar()以后，程序的输出就正确了？我们再次审视程序1,发现main函数屮创建两个子线程后，接下来的语句是 cout«"finished.n&q

11、uot;closehandle(hthread0);closehandle(hthread 1 );联系课本上的内容，线程是能够为os独立调度的执行实体，也就是说，主线程main中创 建两个子线程后，我们的程序中就有了三个能够被os独立调度执行的单元，分别是主线程、 子线程1和子线程2,如果接下來os调度主线程继续执行，那么，主线程将执行 cout«ufinished.nh;closehandle(hthread0);closehtindle(hthread 1 );这几个语句执行的很快，执行完毕后，主线程就退出了，这个时候可能两个可怜的子线程 还没来得及运行过一次，主线程退出的时候

12、，会调用系统函数结束整个进程的运行【这是 编译器自动给我们的程序加入的结束代码】，而进程一旦结束了，那么进程中的其他子线程 也就随之结束了。所以，也就看不到执行结果了。原来是这样子！那我的程序该怎么修改呢？容易，只要把程序逻辑改为“等子线程都运行完 毕后,主线程才结朿”就行啦。在coutvv“finished.n“;之前加上下面的语句就搞定了。waitforsingleobject(hthread0, infinite);waitforsingleobject(hthread 1 , infinite);waitforsingleobject ()是一个神奇的函数，它可以用来等待一个线程或进程

13、的结束，也可 以等待mutex, semaphore和event同步对象，而且它们的等待含义是不一样的。大家要注意理解和区分。到此，代码能够正确运行了，所有的代码如下：#include nwindows.hn#include mprocess.hh#include <iostream.h># include <stdio.h>handle hmutex;unsigned int _stdcall thread 1 (void* p)int i,j；for(i=0;i<5;i+)waitforsingleobject(hmutexjnfinite);for0=0;j

14、<5;j+) cout«uin threadl.m«endl;releasemutex(hmutex);return 0;unsigned int stdcall thread2(void* p)int i,j；for(i=0;i<5;i+)waitforsingleobject(hmutexjnfinite);for(j=0；j<5;j+) cout«nin thread2.n«endl;releasemutex(hmutex);return 0;void main(int argc,char* argv)handle hthread

15、2;unsigned threadid2j;hmutex=createmutex(null,false,null);cout«"creating threadl"«endl; hthreado=(handle)_beginthreadex(null,o, thread 1 ,null,0,&threadido);colit«"creating thread2"«endl;hthread 1 =(handle)_beginthreadex(null,o, thread2,null,0,&thieadi

16、dl);cout«ufinished.nm;waitforsingleobject(hthread0,infinite);waitforsingleobject(hthreadfl,infinite);closehandle(hthread0);closehandle(hthread 1);同学们在多线程编程时遇到的问题整理更新时间：2011-10-9（1）给线程函数传递参数时，传递的是参数的指针，所以，要保证该线程执行时，该参数 的值不会被改变，而且该参数仍然有效。下面的代码不正确，因为，在for循环屮，每次param 变量的值都在变动。从而使得线程通过指针拿到的param的值不是

17、你初始吋想传给线程的 值，而是param变量当前的值，该值已经被你重新赋值了。struct prcoparam int wail_lime;int goods_num;int threadid;；unsigned _stdcall firstthreadfunc(void * arg)procparam *param;param = (procparam*)arg;printf(“d %d %d' param->wait_time, param->goods_num, param->threadid);return 0;int main () procparam pa

18、ram;for(i=0;i<9;i+)param.wait_time = (i+1)*10;param.goods_num = (i+l)*2;param.threadid = i+1;hthreadi = (handle)_beginthreadex(null, 0, firstthreadfunc, (void*)&param, 0, & threadidfi);代码修改方法如下：先定义一个param数组，数组的每个单元存放一个对应线程的参数struct prcoparam)int wait_time;int goods_num;int threadid;unsigned _stdcall firstthreadfunc(void * arg)procparam *param;param = (procparam*)arg;printf(44%d %d %cf param->wait_time, param->goods_num, param->thre