开发者社区> 翡青> 正文
阿里云
为了无法计算的价值
打开APP
阿里云APP内打开

Linux多线程实践(2) --线程基本API

简介: POSIX线程库   与线程有关的函数构成了一个完整的系列,绝大多数函数的名字都是以“pthread_”开头,要使用这些函数库,要通过引入头文,而且链接这些线程函数库时要使用编译器命令的“-l...
+关注继续查看

POSIX线程库

  与线程有关的函数构成了一个完整的系列,绝大多数函数的名字都是以“pthread_”开头,要使用这些函数库,要通过引入头文<pthread.h>,而且链接这些线程函数库时要使用编译器命令的“-lpthread”选项[Ubuntu系列系统需要添加的是”-pthread”选项而不是”-lpthread”,如Ubuntu 14.04版本,深度Ubuntu等]

 

1.pthread_create

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

创建一个新的线程

参数

  thread:线程ID

  attr:设置线程的属性,一般设置为NULL表示使用默认属性

  start_routine:是个函数地址,线程启动后要执行的函数

  arg:传给线程启动函数的参数

返回值:成功返回0;失败返回错误码;

 

附-Posix错误检查

  UNIX传统的函数:成功返回0,失败返回-1,并且对设置全局变量errno以指定错误类型。然而pthreads函数出错时不会设置全局变量errno(而其他的大部分POSIX函数会设置errno)。而是将错误代码通过返回值返回;

  pthreads同样也提供了线程内的errno变量,对于每一个线程, 都有一个errno的值, 以支持其它使用errno的代码。对于pthreads函数的错误,建议通过返回值进行判定,因为读取返回值要比读取线程内的errno变量的开销更小!

/** 实践: 新的错误检查与错误退出函数 **/
inline void err_check(const std::string &msg, int retno)
{
    if (retno != 0)
        err_exit(msg, retno);
}
inline void err_exit(const std::string &msg, int retno)
{
    std::cerr << msg << ": " << strerror(retno) << endl;
    exit(EXIT_FAILURE);
}

2.pthread_exit

void pthread_exit(void *value_ptr);

线程终止

  value_ptr:指向该线程的返回值;注意:value_ptr不能指向一个局部变量

 

3.pthread_join

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

等待线程结束

  value_ptr:它指向一个指针,后者指向线程的返回值(用户获取线程的返回值)

/** 示例: 等待线程退出 **/
void *thread_rotine(void *args)
{
    for (int i = 0; i < 10; ++i)
    {
        printf("B");
        fflush(stdout);
        usleep(20);
    }
    pthread_exit(NULL);
}

int main()
{
    pthread_t thread;
    int ret = pthread_create(&thread, NULL, thread_rotine, NULL);
    err_check("pthread_create", ret);


    for (int i = 0; i < 10; ++i)
    {
        printf("A");
        fflush(stdout);
        usleep(20);
    }

    ret = pthread_join(thread, NULL);
    err_check("pthread_join", ret);
    putchar('\n');
    return 0;
}

4.pthread_self

pthread_t pthread_self(void);

返回线程ID

/** 示例:主控线程与子线程传递数据 **/
typedef struct _Student
{
    char name[20];
    unsigned int age;
} Student;

void *threadFunction(void *args)
{
    cout << "In Thread: " << pthread_self() << endl;
    Student tmp = *(Student *)(args);
    cout << "Name: " << tmp.name << endl;
    cout << "Age: " << tmp.age << endl;

    pthread_exit(NULL);
}

int main()
{
    Student student = {"xiaofang",22};

    pthread_t thread;
    //启动创建并启动线程
    pthread_create(&thread,NULL,threadFunction,&student);
    //等待线程结束
    pthread_join(thread,NULL);

    return 0;
}


5.pthread_cancel

int pthread_cancel(pthread_t thread);

取消一个执行中的线程


6.pthread_detach

int pthread_detach(pthread_t thread);

  将一个线程分离-如果在新创建的线程结束时主线程没有结束同时也没有调用pthread_join,则会产生僵线程,次问题可以通过设置线程为分离的(detach)来解决;

 

总结:进程 VS. 线程

进程(pid_t)

线程(pthread_t)

Fork

Pthread_create

Waitpit

Pthread_join/Pthread_detach

Kill

Pthread_cancel

Pid

Pthead_self

Exit/return

Pthread_exit/return

僵尸进程(没有调用wait/waitpid等函数)

僵尸线程(没有调用pthread_join/pthread_detach)

/** 将并发echo server改造成多线程形式 
注意线程竞速问题的解决
**/
void echo_server(int clientSocket);
void *thread_routine(void *arg);
int main()
{
    int sockfd = socket(AF_INET,SOCK_STREAM,0);
    if (sockfd == -1)
        err_exit("socket error");

    int optval = 1;
    if (setsockopt(sockfd,SOL_SOCKET,SO_REUSEADDR,&optval,sizeof(optval)) == -1)
        err_exit("setsockopt error");

    struct sockaddr_in serverAddr;
    serverAddr.sin_family = AF_INET;
    serverAddr.sin_port = htons(8002);
    serverAddr.sin_addr.s_addr = INADDR_ANY;    //绑定本机的任意一个IP地址
    if (bind(sockfd,(struct sockaddr *)&serverAddr,sizeof(serverAddr)) == -1)
        err_exit("bind error");

    if (listen(sockfd,SOMAXCONN) == -1)
        err_exit("listen error");

    while (true)
    {
        int peerSockfd = accept(sockfd, NULL, NULL);
        if (peerSockfd == -1)
            err_exit("accept error");

        pthread_t tid;
        /**注意: 下面这种用法可能会产生"竞速问题"
                当另一个连接快读快速到达, peerSockfd的内容更改,
                新创建的线程尚未将该值取走时,线程读取的就不是
                我们想让线程读取的值了
        int ret = pthread_create(&tid, NULL, thread_routine, (void *)&peerSockfd);
        **/
        //解决方案: 为每一个链接创建一块内存
        int *p = new int(peerSockfd);
        int ret = pthread_create(&tid, NULL, thread_routine, p);
        if (ret != 0)
            err_thread("pthread_create error", ret);
    }
    close(sockfd);
}
void *thread_routine(void *args)
{
    //将线程设置分离状态, 避免出现僵尸线程
    pthread_detach(pthread_self());
    int peerSockfd = *(int *)args;
    //将值取到之后就将这块内存释放掉
    delete (int *)args;

    echo_server(peerSockfd);
    cout << "thread " << pthread_self() << " exiting ..." << endl;
    pthread_exit(NULL);
}
void echo_server(int clientSocket)
{
    char buf[BUFSIZ] = {0};
    int readBytes;
    while ((readBytes = read(clientSocket, buf, sizeof(buf))) >= 0)
    {
        if (readBytes == 0)
        {
            cerr << "client connect closed" << endl;
            break;
        }
        if (write(clientSocket, buf, readBytes) == -1)
        {
            cerr << "server thread write error" << endl;
            break;
        }
        cout << buf;
        bzero(buf, sizeof(buf));
    }
}

其完整源代码:download.csdn.net/detail/hanqing280441589/8440763


版权声明:本文内容由阿里云实名注册用户自发贡献,版权归原作者所有,阿里云开发者社区不拥有其著作权,亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容,填写侵权投诉表单进行举报,一经查实,本社区将立刻删除涉嫌侵权内容。

相关文章
linux线程的实现【转】
转自:http://www.cnblogs.com/zhaoyl/p/3620204.html   首先从OS设计原理上阐明三种线程:内核线程、轻量级进程、用户线程 内核线程 内核线程就是内核的分身,一个分身可以处理一件特定事情。
863 0
Linux多线程4-1_互斥量
一、为什么要使用互斥量 1、当多个线程共享相同的内存时,需要每一个线程看到相同的视图。当一个线程修改变量时,而其他线程也可以读取或者修改这个变量,就需要对     这些线程同步,确保他们不会访问到无效的变量 2、在变量修改时间多于一个存储器访问周期的处理器结构中,当存储器的读和写这两个周期交叉时,这种潜在的不一致性就会出现。
700 0
Linux多线程3-2_线程连接
一、线程连接的作用     int pthread_join(pthead_t tid, void **rval) 1、调用该函数的线程会一直阻塞,直到指定的线程tid调用pthread_exit、从启动例程返回或者被取消     参数tid就是指定线程的id     参数r...
870 0
Linux多线程实践(4) --线程特定数据
线程特定数据 int pthread_key_create(pthread_key_t *key, void (*destr_function) (void *)); int pthr...
831 0
linux多线程示例
1 #include 2 #include 3 #include 4 #include 5 6 typedef void* (*fun)(void*); 7 8 fun fun1, fun2; 9 10 pthread_mutex_t pmu =...
798 0
linux之线程之互斥
线程概述:   其实在Linux中,新建的线程并不是在原先的进程中,而是系统通过一个系统调用clone()。该系统copy了一个和原先进程完全一样的进程,并在这 个进程中执行线程函数。不过这个copy过程和fork不一样。
962 0
+关注
翡青
阿里巴巴高级研发工程师
211
文章
34
问答
文章排行榜
最热
最新
相关电子书
更多
低代码开发师(初级)实战教程
立即下载
阿里巴巴DevOps 最佳实践手册
立即下载
冬季实战营第三期:MySQL数据库进阶实战
立即下载