快捷導(dǎo)航

C++?pthread入門指南

更新時(shí)間：2024年05月30日 14:20:22 作者：SGchi

pthread是C++98接口且只支持Linux,使用時(shí)需要包含頭文件#include?<pthread.h>,編譯時(shí)需要鏈接pthread庫,其中p是POSIX的縮寫,而POSIX是Portable?Operating?System?Interface的縮寫,這篇文章主要介紹了C++?pthread簡介,需要的朋友可以參考下

一、pthread簡介

pthread是C++98接口且只支持Linux，使用時(shí)需要包含頭文件#include <pthread.h>，編譯時(shí)需要鏈接pthread庫，其中p是POSIX的縮寫，而POSIX是Portable Operating System Interface的縮寫，是IEEE為要在各種UNIX操作系統(tǒng)上運(yùn)行軟件，而定義API的一系列互相關(guān)聯(lián)的標(biāo)準(zhǔn)的總稱。（Windows環(huán)境下無pthread，Linux GCC4.6以下編譯需加-pthread編譯選項(xiàng)）

1、線程創(chuàng)建

int pthread_create (pthread_t *thread,
					pthread_attr_t *attr,
					void *(*start_routine)(void *),void *arg);

若創(chuàng)建成功，返回0；若出錯(cuò)，則返回錯(cuò)誤編號。

thread 是線程標(biāo)識符，但這個(gè)參數(shù)不是由用戶指定的，而是由 pthread_create 函數(shù)在創(chuàng)建時(shí)將新的線程的標(biāo)識符放到這個(gè)變量中。
attr 指定線程的屬性，包含了線程的調(diào)度策略，堆棧的相關(guān)信息，join or detach 的狀態(tài)等，可以用 NULL 表示默認(rèn)屬性。
start_routine 指定線程開始運(yùn)行的函數(shù)。
arg 是 start_routine 所需要的參數(shù)，是一個(gè)無類型指針。

pthread_attr_t 操作函數(shù)：

pthread_attr_t attr; // 聲明attr
pthread_attr_init(&attr);  // 創(chuàng)建attr
pthread_attr_destroy(&attr); // 銷毀attr
pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_JOINABLE); // 設(shè)置為joinable

2、線程終止

void pthread_exit (void *retval);
int pthread_cancel (pthread_t thread);

當(dāng)發(fā)生以下情形之一時(shí)，線程就會結(jié)束：

線程運(yùn)行的函數(shù)return了，也就是線程的任務(wù)已經(jīng)完成；
線程調(diào)用了 pthread_exit 函數(shù)；
其他線程調(diào)用 pthread_cancel 結(jié)束這個(gè)線程；
進(jìn)程調(diào)用 exec() 或 exit()，結(jié)束了；
main() 函數(shù)先結(jié)束了，而且 main() 自己沒有調(diào)用 pthread_exit 來等所有線程完成任務(wù)。

當(dāng)然，一個(gè)線程結(jié)束，并不意味著它的所有信息都已經(jīng)消失，后面會看到僵尸線程的問題。

一個(gè)線程可以通過調(diào)用 pthread_cancel 函數(shù)來請求取消同一進(jìn)程中的線程，這個(gè)線程由thread 參數(shù)指定。如果操作成功則返回0，失敗則返回對應(yīng)的錯(cuò)誤編號。

3、線程同步

int pthread_join(pthread_t threadid, void **value_ptr);
int pthread_detach (threadid);

阻塞是線程之間同步的一種方法。pthread_join 函數(shù)會讓調(diào)用它的線程等待 threadid 線程運(yùn)行結(jié)束之后再運(yùn)行，value_ptr 存放了其他線程的返回值。
一個(gè)可以被join的線程，僅僅可以被別的一個(gè)線程 join，如果同時(shí)有多個(gè)線程嘗試 join 同一個(gè)線程時(shí)，最終結(jié)果是未知的。另外，線程不能 join 自己。

值得注意的的是：僵尸線程 ( “zombie” thread )是一種已經(jīng)退出了的 joinable 的線程，但是等待其他線程調(diào)用
pthread_join 來 join 它，以收集它的退出信息(exit status)。如果沒有其他線程調(diào)用 pthread_join 來
join 它的話，它占用的一些系統(tǒng)資源不會被釋放，比如堆棧。如果main()函數(shù)需要長時(shí)間運(yùn)行，并且創(chuàng)建大量 joinable的線程，就有可能出現(xiàn)堆棧不足的 error 。對于那些不需要 join 的線程，最好利用
pthread_detach，這樣它運(yùn)行結(jié)束后，資源就會及時(shí)得到釋放。注意一個(gè)線程被使用 pthread_detach
之后，它就不能再被改成 joinable 的了。總而言之，創(chuàng)建的每一個(gè)線程都應(yīng)該使用 pthread_join 或者
pthread_detach 其中一個(gè)，以防止僵尸線程的出現(xiàn)。

4、其他函數(shù)

pthread_self (); // 返回當(dāng)前線程的 thread ID
pthread_equal (thread1,thread2); // pthread_equal 比較兩個(gè)線程的 ID，如果不同則返回0，否則返回一個(gè)非零值
// 互斥鎖
pthread_mutex_t mutexsum;
pthread_mutex_init (mutex,attr);
pthread_mutex_destroy (pthread_mutex_t *mutex);
pthread_mutexattr_init (attr);
pthread_mutexattr_destroy (attr);
phtread_mutex_lock(pthread_mutex_t *mutex);
phtread_mutex_trylock(pthread_mutex_t *mutex);
phtread_mutex_unlock(pthread_mutex_t *mutex);

5、示例代碼

#include<stdlib.h>
#include <pthread.h>
#include <stdio.h>
#include <math.h>
#define NUM_THREADS 4
void *BusyWork(void *t)
{
    int i;
    long tid;
    double result = 0.0;
    tid = (long) t;
    printf("Thread %ld starting...\n", tid);
    for (i = 0; i < 1000000; i++)
    {
        result = result + sin(i) * tan(i);
    }
    printf("Thread %ld done. Result = %e\n", tid, result);
    pthread_exit((void *) t);
}
int main(int argc, char *argv[])
{
    pthread_t thread[NUM_THREADS];
    pthread_attr_t attr;
    int rc;
    long t;
    void *status;
/* Initialize and set thread detached attribute */
    pthread_attr_init(&attr);
    pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_JOINABLE);
    for (t = 0; t < NUM_THREADS; t++)
    {
        printf("Main: creating thread %ld\n", t);
        rc = pthread_create(&thread[t], &attr, BusyWork, (void *) t);
        if (rc)
        {
            printf("ERROR; return code from pthread_create() is %d\n", rc);
            exit(-1);
        }
    }
/* Free attribute and wait for the other threads */
    pthread_attr_destroy(&attr);
    for (t = 0; t < NUM_THREADS; t++)
    {
        rc = pthread_join(thread[t], &status);
        if (rc)
        {
            printf("ERROR; return code from pthread_join() is %d\n", rc);
            exit(-1);
        }
        printf("Main: completed join with thread %ld having a status of %ld\n", t, (long) status);
    }
    printf("Main: program completed. Exiting.\n");
    pthread_exit(NULL);
}

Main: creating thread 0
Main: creating thread 1
Thread 0 starting...
Thread 1 starting...
Main: creating thread 2
Main: creating thread 3
Thread 2 starting...
Thread 3 starting...
Thread 1 done. Result = -3.153838e+06
Thread 0 done. Result = -3.153838e+06
Main: completed join with thread 0 having a status of 0
Main: completed join with thread 1 having a status of 1
Thread 3 done. Result = -3.153838e+06
Thread 2 done. Result = -3.153838e+06
Main: completed join with thread 2 having a status of 2
Main: completed join with thread 3 having a status of 3
Main: program completed. Exiting.

參考鏈接：C++ 多線程編程（二）：pthread的基本使用

到此這篇關(guān)于C++ pthread入門指南的文章就介紹到這了,更多相關(guān)C++ pthread內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: