多线程如何才能等待任务执行完成才停止

korpus

假设总共有5个线程，其中4个在read中，另一个正在处理任务。

这时候需要停止系统做更新操作等，我希望程序的停止是在这个线程任务处理完成后才正常停止。如何做？谢谢啦~~~~

pthread_cancel只要发送信号到线程了，线程接收到就退出了，那么就会造成有些任务只处理到一半。。。

korpus

现在想的是，如果自己在做任务，然后就去注册一下。感觉麻烦，pthread_cancel能解决吗

korpus

现在想的是，如果自己在做任务，然后就去注册一下。感觉麻烦，pthread_cancel能解决吗

foolishx

可以手动设置线程退出的时机。
通过 int pthread_setcanceltype(int type, int *oldtype)
设置本线程取消动作的执行时机，type由两种取值：PTHREAD_CANCEL_DEFFERED和 PTHREAD_CANCEL_ASYNCHRONOUS，仅当Cancel状态为Enable时有效，分别表示收到信号后继续运行至下一个取消点再退出和 立即执行取消动作（退出）；oldtype如果不为NULL则存入运来的取消动作类型值。
此函数应该在线程开始时执行，若线程内部有任何资源申请等操作，应该选择 PTHREAD_CANCEL_DEFFERED 的设定，然后在退出点（pthread_testcancel 用于定义退出点）进行线程退出。
void pthread_testcancel(void)
检查本线程是否处于Canceld状态，如果是，则进行取消动作，否则直接返回。 此函数在线程内执行，执行的位置就是线程退出的位置，在执行此函数以前，线程内部的相关资源申请一定要释放掉，他很容易造成内存泄露。

群雄逐鹿中原

我还没碰到过要用 pthread_cancel 的场合。

这函数设计出来算一种bug吗？

foolishx

我大致理解你的运用场景了。一般通用的做法是这样的：
在新线程的入口程序里面通常会有如下代码段：

while(sys_state != SYS_SHUT_DOWN)
{
           if(hasJobs())
           {
            //here process you jobs
           }
           else
            {
               sleep(nnnnn);//等着任务的到来
            }
｝
接下来的代码就是函数返回及线程退出之前的资源回收了
一般都不会主动使用thread_cancel来结束线程。线程执行的代码段结束了，它自己会退出的，你只需要考虑什么时候让它的代码段结束就行了。

korpus

回复 4# foolishx

#include <pthread.h>
#include <sys/types.h>
#include <unistd.h>
#include <stdio.h>
#include <stdlib.h>

void *thread(void* m)
{
        pthread_setcancelstate( PTHREAD_CANCEL_ENABLE, NULL);     //??????
       // pthread_setcanceltype(PTHREAD_CANCEL_ASYNCHRONOUS, NULL); //??????
        pthread_setcanceltype(PTHREAD_CANCEL_DEFERRED, NULL); //??????
        unsigned long  t,id;
        t = *(unsigned long *)m;
        while(1)
        {
                printf("thread %ld\n",pthread_self()); //??????
                sleep(3);
//                pthread_testcancel();
        }
}




int main()
{
        pthread_t t[2];
        pthread_attr_t at;
        int ret, i;
        for(i = 0; i < 2;i++)
        {
                ret = pthread_create(&t,NULL,thread,&i);
                if(ret!=0)
                {
                        printf ("Create pthread error!n");
                        exit (1);
                }
printf("%ld\n", t);




        }
        while(1){
//                pthread_cancel(t[0]); //10???,???????. t??????
//                pthread_cancel(t[1]); //10???,???????. t??????
                sleep(10);
                pthread_cancel(t[1]); //10???,???????. t??????
                pthread_cancel(t[0]); //10???,???????. t??????
        }
}




现在感觉很奇怪




测试代码如上，   如果我给线程1,2都发送了cancel信号，但是由于线程中没有cancel点，所以一直卡在，但为什么printf的都没有打了呢？








如果我在线程1,2都加上pthread_testcancel()，线程没有正常退出，线程也没有打印printf的内容




如果主线程只给一个线程发送cancel信号，则无论有没有pthread_testcancel() 线程都会退出一个。。。。




   

foolishx

回复 7# korpus

先说说你代码里存在的问题：
int main()
{
        pthread_t t[2];
        pthread_attr_t at;
        int ret, i;
        for(i = 0; i < 2;i++)
        {
                ret = pthread_create(&t ,NULL,thread,&i);
                if(ret!=0)
                {
                        printf ("Create pthread error!n");
                        exit (1);
                }
printf("%ld\n", t);




        }
        while(1){
//                pthread_cancel(t[0]); //10???,???????. t??????
//                pthread_cancel(t[1]); //10???,???????. t??????
                sleep(10);
                pthread_cancel(t[1]); //10???,???????. t??????
                pthread_cancel(t[0]); //10???,???????. t??????
        }
}
由于上述代码存在的问题，会导致你丢失了第一个线程的id，于是之后所有对于线程1的操作都将没有办法准确的进行，同时对于t[1]的操作将是不可知的结果 。修正之后再看看问题如何   

yulihua49

korpus 发表于 2013-05-24 13:00
假设总共有5个线程，其中4个在read中，另一个正在处理任务。

这时候需要停止系统做更新操作等，我希望程 ...

pthread_join();