pthread_create

#include <pthread.h>

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

       Compile and link with -pthread.

编译时应注意。

#include<iostream>
#include<string>
#include<vector>
#include<pthread.h>
#include<unistd.h>

using namespace std;

void *start_routine(void *args)
{
    string name=static_cast<char*>(args);
    while(true)
    {
        cout<<"new thread create success , name: "<<name<<endl;
        sleep(1);
    } 
}

int main()
{
    // vector<pthread_t> tids; 
#define NUM 10
    for(int i=0;i<NUM;i++)
    {
        pthread_t tid;
        char namebuffer[64];
        snprintf(namebuffer,sizeof(namebuffer),"%s:%d","thread",i);
      //pthread_create  
        pthread_create(&tid,nullptr,start_routine,namebuffer);
 //     pthread_create(&tid,nullptr,start_routine,(void*)"thread one");
        sleep(1);
    }
    while(true)
    {
        cout<<"new thread create success,name : main thread"<<endl;
        sleep(1);
    }
    return 0;
}

//可重入函数->void *start_routine(void *args)

//局部变量具有临时性,在多线程中也适用--->每个线程都有自己独立的栈结构

cnt: 9 &cnt   0x7fa036708ef4
cnt: 9 &cnt   0x7fa035f07ef4
cnt: 9 &cnt   0x7fa035706ef4
cnt: 9 &cnt   0x7fa034f05ef4
cnt: 9 &cnt   0x7fa034704ef4
cnt: 9 &cnt   0x7fa033f03ef4
cnt: 9 &cnt   0x7fa033702ef4
cnt: 9 &cnt   0x7fa032f01ef4
cnt: 9 &cnt   0x7fa032700ef4
cnt: 9 &cnt   0x7fa031effef4

void *start_routine(void *args)
{
    sleep(1);
    ThreadData *td=static_cast<ThreadData*>(args);
    int cnt=10;
    while(cnt)
    {
        cout<<"cnt: "<<cnt<<" &cnt   "<<&cnt<<endl;
        cnt--;
        // cout<<"new thread create success , name: "<<td->namebuffer<<" cnt: "<<cnt--<<endl;
        sleep(1);
    } 
    delete td;
    return nullptr;
}

#include<iostream>
#include<string>
#include<vector>
#include<pthread.h>
#include<unistd.h>

using namespace std;
class ThreadData
{
public:
    pthread_t tid;
    char namebuffer[64];
};
//可重入函数
//局部变量具有临时性,在多线程中也适用--->每个线程都有自己独立的栈结构
void *start_routine(void *args)
{
    sleep(1);
    ThreadData *td=static_cast<ThreadData*>(args);
    int cnt=10;
    while(cnt)
    {
        cout<<"cnt: "<<cnt<<" &cnt   "<<&cnt<<endl;
        cnt--;
        // cout<<"new thread create success , name: "<<td->namebuffer<<" cnt: "<<cnt--<<endl;
        sleep(1);
    } 
    delete td;
    return nullptr;
}

int main()
{
    vector<ThreadData*> threads; 

#define NUM 10
    for(int i=0;i<NUM;i++)
    {
        ThreadData *td=new ThreadData(); 
        // char namebuffer[64];
        snprintf(td->namebuffer,sizeof(td->namebuffer),"%s:%d","thread",i+1);
      //pthread_create  
        pthread_create(&td->tid,nullptr,start_routine,td);
 //     pthread_create(&tid,nullptr,start_routine,(void*)"thread one");
        // sleep(1);
        threads.push_back(td);
    }

    for(auto &iter:threads)
    {
        cout<<"create thread: "<<iter -> namebuffer << ":"<<iter->tid<<" success"<<endl;
    }

    while(true)
    {
        cout<<"new thread create success,name : main thread"<<endl;
        sleep(1); 
    }
    return 0;
}

pthread_exit

#include <pthread.h>

       void pthread_exit(void *retval);

       Compile and link with -pthread.

//可重入函数
//局部变量具有临时性,在多线程中也适用--->每个线程都有自己独立的栈结构
void *start_routine(void *args)
{
    sleep(1);
    ThreadData *td=static_cast<ThreadData*>(args);
    int cnt=10;
    while(cnt)
    {
        cout<<"cnt: "<<cnt<<" &cnt   "<<&cnt<<endl;
        cnt--;
        // cout<<"new thread create success , name: "<<td->namebuffer<<" cnt: "<<cnt--<<endl;
        sleep(1);
        pthread_exit(nullptr);//-> return nullptr
        // //任何一个执行流调exit整个进程都会退出
        // exit(0);//不能用来终止线程
    } 
    delete td;
    //return nullptr;//线程函数结束，return的时候线程就算终止了
}

pthread_exit(nullptr);//-> return nullptr

线程等待：pthread_join

       #include <pthread.h>

       int pthread_join(pthread_t thread, void **retval);

       Compile and link with -pthread.
 

线程异常，收到信号，整个进程都会退出。

线程取消： pthread_cancel

       #include <pthread.h>

       int pthread_cancel(pthread_t thread);
       int pthread_cancel(pthread_t thread);

       Compile and link with -pthread.

 线程如果是被取消的，退出码： -1(PTHREAD_CANCELED);