• <ins id="pjuwb"></ins>
    <blockquote id="pjuwb"><pre id="pjuwb"></pre></blockquote>
    <noscript id="pjuwb"></noscript>
          <sup id="pjuwb"><pre id="pjuwb"></pre></sup>
            <dd id="pjuwb"></dd>
            <abbr id="pjuwb"></abbr>

            小默

            thread 取消線程

            取消一個(gè)線程

            可以請(qǐng)求一個(gè)線程終止,像給它發(fā)送一個(gè)信號(hào)一樣.

            1 請(qǐng)求端:

            #include <pthread.h>
            int pthread_cancel(pthread_t thread);
            請(qǐng)求取消指定線程.

            2 接收請(qǐng)求端:

            #include <pthread.h>
            int pthread_setcancelstate(int state, int *oldstate);
            state: 線程是否接收取消請(qǐng)求.
            | PTHREAD_CANCEL_ENABLE 允許線程接收取消請(qǐng)求
            | PTHREAD_CANCEL_DISABLE 忽略取消請(qǐng)求
            oldstate: 獲取先前的取消狀態(tài),不關(guān)心先前狀態(tài)傳NULL.

            #include <pthread.h>
            int pthread_setcanceltype(int type, int *oldtype);
            type: 如果接收到取消請(qǐng)求,什么時(shí)候采取行動(dòng).
            | PTHREAD_CANCEL_ASYNCHRONOUS 接收到取消請(qǐng)求后立即采取行動(dòng).
            | PTHREAD_CANCEL_DEFERRED 接收到取消請(qǐng)求后,等待請(qǐng)求端線程執(zhí)行以下函數(shù)之一,再采取行動(dòng).
            |    (pthread_join,pthread_cond_wait, pthread_cond_timedwait, pthread_testcancel, sem_wait, sigwait)
            oldtype: 獲取先前的取消狀態(tài),不關(guān)心先前狀態(tài)傳NULL.

            取消一個(gè)線程:
            /*
             * 取消一個(gè)線程
             
            */
            #include 
            <stdio.h>
            #include 
            <unistd.h>
            #include 
            <stdlib.h>
            #include 
            <pthread.h>

            void *thread_function(void *arg);

            int main(){
                
            int res;
                pthread_t a_thread;
                
            void *thread_result;

                res 
            = pthread_create(&a_thread, NULL, thread_function, NULL);
                
            if(res != 0){
                    perror(
            "Thread creation failed");
                    exit(EXIT_FAILURE);
                }

                sleep(
            3);
                printf(
            "Canceling thread\n");
                res 
            = pthread_cancel(a_thread);
                
            if(res != 0){
                    perror(
            "Thread cancelation failed");
                    exit(EXIT_FAILURE);
                }

                printf(
            "Waiting for thread to finished\n");
                res 
            = pthread_join(a_thread, &thread_result);
                
            if(res != 0){
                    perror(
            "Thread join failed");
                    exit(EXIT_FAILURE);
                }

                exit(EXIT_SUCCESS);
            }

            void *thread_function(void *arg){
                
            int i,res;

                res 
            = pthread_setcancelstate(PTHREAD_CANCEL_ENABLE, NULL);
                
            if(res != 0){
                    perror(
            "Thread pthread_setcancelstate failed");
                    exit(EXIT_FAILURE);
                }

                res 
            = pthread_setcanceltype(PTHREAD_CANCEL_DEFERRED, NULL);
                
            if(res != 0){
                    perror(
            "Thread pthread_setcanceltype failed");
                    exit(EXIT_FAILURE);
                }
                printf(
            "thread_function is running\n");

                
            for(i = 0; i < 10; i++){
                    printf(
            "Thread is still running (%d)\n", i);
                    sleep(
            1);
                }

                pthread_exit(
            0);
            }

            運(yùn)行結(jié)果:
            $ gcc -D_REENTRANT thread7.c -o thread7 -lpthread
            $ .
            /thread7
            thread_function 
            is running
            Thread 
            is still running (0)
            Thread 
            is still running (1)
            Thread 
            is still running (2)
            Canceling thread
            Waiting 
            for thread to finished

            --
            FROM:Linux程序設(shè)計(jì)

            posted on 2011-06-14 19:45 小默 閱讀(676) 評(píng)論(0)  編輯 收藏 引用 所屬分類: Linux

            導(dǎo)航

            統(tǒng)計(jì)

            留言簿(13)

            隨筆分類(287)

            隨筆檔案(289)

            漏洞

            搜索

            積分與排名

            最新評(píng)論

            閱讀排行榜

            久久99国产精一区二区三区| 岛国搬运www久久| 日本精品久久久久中文字幕8 | 久久久久亚洲精品天堂| 精品久久久久久无码免费| 国产精品免费福利久久| 亚洲精品无码专区久久久| 久久精品人成免费| 国产精品青草久久久久婷婷| 18岁日韩内射颜射午夜久久成人| 久久丝袜精品中文字幕| 国产一区二区三区久久精品| 日韩久久久久久中文人妻 | 2021精品国产综合久久| 国産精品久久久久久久| 伊人久久大香线焦AV综合影院| 久久婷婷综合中文字幕| 精品久久久久久无码不卡| 久久精品国内一区二区三区| 国产69精品久久久久APP下载 | 99久久国产综合精品女同图片| 久久99毛片免费观看不卡| 亚洲人AV永久一区二区三区久久| 精品免费久久久久久久| 国产69精品久久久久APP下载| 久久久精品免费国产四虎| 一本一本久久A久久综合精品| 久久国产视频网| 久久美女网站免费| 久久精品国产亚洲av麻豆小说| 亚洲精品无码久久久| 激情久久久久久久久久| 韩国三级大全久久网站| 人妻无码αv中文字幕久久| 一本久道久久综合狠狠躁AV| 久久国产视频99电影| 国产成人精品久久综合| 青青草原综合久久大伊人精品| 久久精品无码一区二区无码| 久久亚洲sm情趣捆绑调教| 欧美激情精品久久久久久久九九九|