• <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>

            Prayer

            在一般中尋求卓越
            posts - 1256, comments - 190, trackbacks - 0, articles - 0
              C++博客 :: 首頁(yè) :: 新隨筆 :: 聯(lián)系 :: 聚合  :: 管理

            Posix Threads 筆記9 -- Threads and Signals

            Posted on 2009-11-17 15:19 Prayer 閱讀(666) 評(píng)論(1)  編輯 收藏 引用 所屬分類(lèi): LINUX/UNIX/AIX
            #include <signal.h>

            int pthread_sigmask(int how, const sigset_t *restrict set,
            sigset_t *restrict oset);
                                                                                  Returns: 0 if OK, error number on failure

            說(shuō)明:
            1. 每個(gè)線(xiàn)程都有自己獨(dú)立的信號(hào)屏蔽,但卻共享進(jìn)程的信號(hào)處理。這意味著在一個(gè)線(xiàn)程中改變信號(hào)處理,會(huì)影響到其他線(xiàn)程。
            2. 創(chuàng)建新線(xiàn)程時(shí),新線(xiàn)程繼承主線(xiàn)程的當(dāng)前信號(hào)屏蔽。
            3. 當(dāng)信號(hào)是由于硬件錯(cuò)誤或者定時(shí)器溢出而引起時(shí),信號(hào)被發(fā)往引起該信號(hào)的線(xiàn)程;其他情況下,信號(hào)送往進(jìn)程的隨意一個(gè)線(xiàn)程。
            4. pthread_sigmask 是多線(xiàn)程下的信號(hào)屏蔽設(shè)置函數(shù),參數(shù)與 sigprocmask 類(lèi)似。后者在多線(xiàn)程環(huán)境下,行為未定義。



            #include <signal.h>

            int sigwait(const sigset_t *restrict set, int *restrict signop);
                                                                               Returns: 0 if OK, error number on failure

            說(shuō)明:
            1. 使用 sigwait 等待特定信號(hào)前,首先要屏蔽該信號(hào),進(jìn)入sigwait 后會(huì)自動(dòng)解除阻塞,sigwait 返回前,重新恢復(fù)信號(hào)屏蔽。
            2. sigwait 提供了異步信號(hào)的同步處理方式—— 可以在每個(gè)線(xiàn)程中屏蔽信號(hào),而選特定的一個(gè)或多個(gè)線(xiàn)程去處理信號(hào)。在線(xiàn)程的上下文中處理信號(hào),而不在傳統(tǒng)的打斷線(xiàn)程執(zhí)行的信號(hào)句柄。
            3. 當(dāng)有多個(gè)線(xiàn)程都調(diào)用 sigwait 等待同一信號(hào)時(shí),信號(hào)到達(dá)時(shí),只有一個(gè)線(xiàn)程的 sigwait 會(huì)返回。另外當(dāng)信號(hào)句柄與sigwait 同時(shí)存在時(shí),信號(hào)的處理取決于實(shí)現(xiàn),但兩者只能取其一。
            4. APUEv2 給出的例子如下:

            #include "apue.h"
            #include <pthread.h>

            int quitflag; /* set nonzero by thread */
            sigset_t mask;

            pthread_mutex_t lock = PTHREAD_MUTEX_INITIALIZER;
            pthread_cond_t wait = PTHREAD_COND_INITIALIZER;

            void *
            thr_fn(void *arg)
            {
            int err, signo;

            for (;;) {
            err = sigwait(&mask, &signo);
            if (err != 0)
            err_exit(err, "sigwait failed");
            switch (signo) {
            case SIGINT:
            printf("\ninterrupt\n");
            break;

            case SIGQUIT:
            pthread_mutex_lock(&lock);
            quitflag = 1;
            pthread_mutex_unlock(&lock);
            pthread_cond_signal(&wait);
            return(0);

            default:
            printf("unexpected signal %d\n", signo);
            exit(1);
            }
            }
            }
            int
            main(void)
            {
            int err;
            sigset_t oldmask;
            pthread_t tid;

            sigemptyset(&mask);
            sigaddset(&mask, SIGINT);
            sigaddset(&mask, SIGQUIT);
            if ((err = pthread_sigmask(SIG_BLOCK, &mask, &oldmask)) != 0)
            err_exit(err, "SIG_BLOCK error");

            err = pthread_create(&tid, NULL, thr_fn, 0);
            if (err != 0)
            err_exit(err, "can't create thread");

            pthread_mutex_lock(&lock);
            while (quitflag == 0)
            pthread_cond_wait(&wait, &lock);
            pthread_mutex_unlock(&lock);

            /* SIGQUIT has been caught and is now blocked; do whatever */
            quitflag = 0;

            /* reset signal mask which unblocks SIGQUIT */
            if (sigprocmask(SIG_SETMASK, &oldmask, NULL) < 0)
            err_sys("SIG_SETMASK error");
            exit(0);
            }



            #include <signal.h>

            int pthread_kill(pthread_t thread, int signo);

                                                                                   Returns: 0 if OK, error number on failure

            說(shuō)明:
            1. 該函數(shù)用來(lái)向線(xiàn)程發(fā)送信號(hào)。
            2. 如果信號(hào)默認(rèn)會(huì)終止進(jìn)程,則向線(xiàn)程發(fā)送該信號(hào)會(huì)終止線(xiàn)程所在的進(jìn)程。
            3. 定時(shí)器(alarm_timer)是進(jìn)程資源,進(jìn)程的所有線(xiàn)程共享同一套定時(shí)器。所以在線(xiàn)程中同時(shí)設(shè)置定時(shí)器會(huì)相互干擾。

            Feedback

            # re: Posix Threads 筆記9 -- Threads and Signals  回復(fù)  更多評(píng)論   

            2009-11-30 17:44 by seven
            請(qǐng)教下啊
            如果我想寫(xiě)一個(gè)多線(xiàn)程的Ping,每個(gè)線(xiàn)程Ping一個(gè)IP地址,如果Ping過(guò)程中用的是SIGALRM這個(gè)信號(hào)量來(lái)控制每個(gè)線(xiàn)程總的sendto()。該如何實(shí)現(xiàn)呢?
            如果每個(gè)線(xiàn)程都調(diào)用SIGALRM的處理函數(shù)會(huì)不會(huì)出現(xiàn)沖突之類(lèi)的?
            不懂這方面的哎。。。。
            色天使久久综合网天天| 奇米影视7777久久精品人人爽| 人妻无码αv中文字幕久久琪琪布 人妻无码精品久久亚瑟影视 | 精品久久久久一区二区三区| 无码国内精品久久综合88 | 精品久久国产一区二区三区香蕉| 婷婷久久综合| 久久亚洲综合色一区二区三区| 91久久九九无码成人网站| 香蕉久久av一区二区三区| 久久精品视频网| 国产日产久久高清欧美一区| 伊人久久大香线蕉精品不卡| 亚洲国产成人久久一区久久 | 2021国产成人精品久久| 久久久精品人妻一区二区三区蜜桃| 久久国产成人精品国产成人亚洲| 久久综合久久自在自线精品自| 久久99精品免费一区二区| 精品久久久久久| 99久久夜色精品国产网站 | 99久久99这里只有免费的精品| 思思久久精品在热线热| 久久精品亚洲男人的天堂| 久久久久久无码国产精品中文字幕 | 国产精品无码久久综合| AV无码久久久久不卡蜜桃| 亚洲中文字幕无码久久2020| 久久久无码精品亚洲日韩京东传媒| 精品视频久久久久| 91精品婷婷国产综合久久| 国产精品成人精品久久久 | 伊人伊成久久人综合网777| 国产AV影片久久久久久| 日韩欧美亚洲综合久久影院d3| 久久久久久a亚洲欧洲aⅴ| 亚洲欧美精品伊人久久| 国产精品成人精品久久久| 亚洲国产成人久久笫一页| 漂亮人妻被中出中文字幕久久 | 久久超乳爆乳中文字幕|