请教下线程的问题

chary8088

传入的时候是不一样的，在线程函数调用时，我单步看了传入的参数是正确的

chary8088

自己UP，
再测试下

ssafa

看了一下，如果传入的lpHt->siFrom；lpHt ->siTo;是正确的话，liFrom、liTo就不会出错，应该还是传入的那块出了，在仔细看看那一块的代码吧。

speeder

楼主代码没体现出线程啊，问题描述不清楚。
我也来猜测一下。应该是传入参数avOpt 的问题。
你在创建线程之前给avOpt做个拷贝，然后把拷贝传进来。
你现在这个avOpt是个共享对象。

chary8088

原帖由 timespace 于 2008-11-19 13:36 发表
大胆的猜测下你的线程创建和参数使用方式：
for (i = 0; i < threadNum; i++) {
      avOpt->siFrom = f(i); /* siFrom是i的函数,即f(i) */
      avOpt->to = g(i); /* 解释同上 */
      
      /* 其它 ...

是啊，的确是啊，真是说到我心上了！！！
我在单步调试时发现传进去的参数是很正确的，但是在线程执行时发现使用的参数全部是for循环的最后一个的值！！！！！
真是妙手神医！！！

chary8088

for (int i = 0; i < THREAD_NUM; i++)  //total thread's number
        {
                liTo = ((ciFileLen)/THREAD_NUM)*(i + 1);//ciFileLen 文件的大小

                lpInfo.siFrom = liFrom;
                if (i == THREAD_NUM -1)
                {
                        lpInfo.siTo = ciFileLen;
                }
                else
                        lpInfo.siTo = liTo;
                lpInfo.spHp = this;
#ifdef WIN32
                hThread =(HANDLE) _beginthread(ReceiveThreadEx, NULL, &lpInfo);
#else
                pthread_create(thread_id, NULL, ReceiveThread, &lpInfo);
#endif
                liThrNum += 1;
                liFrom = liTo + 1;

        }
我是这样赋值的！！！

timespace

原因上面也解释了，简单的替代方案是：
lpInfo.siFrom lpInfo.siTo都声明为 int *
lpInfo.siFrom = malloc(sizeof(int) * THREAD_NUM)
lpInfo.siTo = malloc(sizeof(int) * THREAD_NUM)
即为每个线程的siFrom siTo 分配独立的内存，避免线程调度的随机性问题

或者以显式同步的方式，确保下次for循环之前，线程内部的
     liFrom = lpHt->siFrom;
     liTo = lpHt ->siTo;
均已执行，不过实现复杂些，得不尝失，不如分配独立内存的方式简单实用

ynchnluiti

原帖由 chary8088 于 2008-11-19 15:41 发表
for (int i = 0; i < THREAD_NUM; i++)  //total thread's number
        {
                liTo = ((ciFileLen)/THREAD_NUM)*(i + 1);//ciFileLen 文件的大小

                lpInfo.siFrom = liFrom;
                if (i == THREAD_NUM -1)
                {
         ...

不会只有一个lpInfo吧。
TYPE lpInfo[THREAD_NUM];