示例 demo

最簡單的 demo：

static?void*?thread1_func(void?*arg)
{
????int?i?=?0;

????//?able?to?be?cancel
????pthread_setcancelstate(PTHREAD_CANCEL_ENABLE,?NULL);
????pthread_setcanceltype(PTHREAD_CANCEL_DEFERRED,?NULL);

????for(i=0;?;?i++)?{
????????printf("thread1?%d
",?i);
????????sleep(1);
????}
}

int?main(int?argc,?char?**argv)
{
????pthread_t?t;
????void?*res;

????pthread_create(&t,?NULL,?thread1_func,?NULL);

????sleep(3);
????pthread_cancel(t);??????????//?cancel?thread1
????pthread_join(t,?&res);??????//?wait?thread1

????if?(res?==?PTHREAD_CANCELED)
????????printf("thread1?was?terminate?by?cancel
");
????else
????????printf("thread1?was?not?terminate?by?cancel
");

????exit(EXIT_SUCCESS);
}

為了突出重點(diǎn)，省略了檢查返回值。

運(yùn)行效果:

thread1?0
thread1?1
thread1?2
thread1?was?terminate?by?cancel

主線程先創(chuàng)建線程 thread1，然后睡眠 3 秒后發(fā)出終止 thread1 的請求。

接收到終止請求后，thread1 會在合適的時機(jī)被終止掉。

主線程通過 pthread_join() 阻塞等待 thread1 退出。

幾個要點(diǎn)

線程終止的 4 種方式：

1. 線程的執(zhí)行函數(shù)返回了，這和 main() 函數(shù)結(jié)束類似。

2. 線程調(diào)用了 pthread_exit() 函數(shù)，這和調(diào)用 exit() 返回類似。

3. 線程被另一個線程通過 pthread_cancel() 函數(shù)取消，這和通過kill() 發(fā)送 SIGKILL 信號類似。

4. 進(jìn)程終止了，則進(jìn)程中的所有線程也會終止。

取消某個線程的常規(guī)步驟

被取消的線程：

1. 允許取消，pthread_setcancelstate()，參數(shù)可選值：

• PTHREAD_CANCEL_ENABLE，這是默認(rèn)值;
• PTHREAD_CANCEL_DISABLE;

• 設(shè)置取消類型，pthread_setcanceltype()，參數(shù)可選值：

• PTHREAD_CANCEL_ASYNCHRONOUS，異步方式，當(dāng)發(fā)出取消請求后，線程可能會在任何點(diǎn)被殺死。

• PTHREAD_CANCEL_DEFERRED，延遲方式，線程只會在特定的取消點(diǎn)（cancellation points，調(diào)用某個函數(shù)前）被殺死。

發(fā)起取消的線程：

3. 發(fā)送取消要求，pthread_cancel()，發(fā)出取消請求后，pthread_cancel() 當(dāng)即返回，不會等待目標(biāo)線程的退出。

4. 等待取消完成，pthread_join()。

哪些函數(shù)是取消點(diǎn)？

POSIX.1 指定了哪些函數(shù)一定是取消點(diǎn)：

更多關(guān)于取消點(diǎn)的介紹：

$?man?7?pthreads
??Cancellation?points
????...
????????accept()
????????aio_suspend()
????????clock_nanosleep()
????????close()
????????...

閱讀開源軟件 MJPG-streamer

MJPG-streamer 是什么？

簡單地說，就是一個開源的流媒體服務(wù)器：

https://github.com/jacksonliam/mjpg-streamer

通過 mjpg-streamer，你可以通過 PC 瀏覽器訪問到板子上的攝像頭圖像。

MJPG-streamer 是如何結(jié)束工作線程的？

MJPG-streamer 運(yùn)行時一般會有 3 個線程:

• 主線程;
• 負(fù)責(zé)數(shù)據(jù)的輸入的線程 (例如 camera capture thread);
• 負(fù)責(zé)輸出數(shù)據(jù)的線程 (例如 http server thread).

以 http server thread 為例：

plugins/output_http/httpd.c

void?*server_thread(void?*arg)
{
????...
????pthread_cleanup_push(server_cleanup,?pcontext);
????
????//?處理連接
????while(!pglobal->stop)?{
????????...
????}
????pthread_cleanup_pop(1);
}

pthread_cleanup_push() 用于注冊清理函數(shù)到棧中，當(dāng)線程遭取消時，會沿該棧自頂向下依次執(zhí)行清理函數(shù)。

當(dāng)用戶通過按下 ctrl + c 要求結(jié)束程序時，主線程會要求殺掉 http server thread 等各種線程：

static?void?signal_handler(int?sig)
{
????
????for(i?=?0;?i?