Linux下开发-线程详解

2015/12/14 - C/C++

其实在Linux中,新建的线程并不是在原先的进程中,而是系统通过一个系统调用clone()。该copy了一个和原先进程完全一样的进程。不过这个copy过程和fork不一样。copy后的进程和原先的进程共享了所有的变量,运行环境(clone的实现是可以指定新进程与老进程之间的共享关系,100%共享就表示创建了一个线程)。这样,原先进程中的变量变动在copy后的进程中便能体现出来。

pthread_detach

如果线程是joinable状态,当线程函数自己返回退出时或pthread_exit时都不会释放线程所占用堆栈和线程描述符(总计8K多)。只有当你调用了pthread_join之后这些资源才会被释放

若是unjoinable状态的线程,这些资源在线程函数退出时或pthread_exit时自动会被释放

unjoinable属性可以在pthread_create时指定,或在线程创建后在线程中pthread_detach自己,如:pthread_detach(pthread_self()),将状态改为unjoinable状态,确保资源的释放。或者将线程置为joinable,然后适时调用pthread_join。

Thread Specific Data

表面上看起来这是一个全局变量,所有线程都可以使用它,而它的值在每一个线程中又是单独存储的。

#include <malloc.h>  
#include <pthread.h>    
#include <stdio.h>  

/* The key used to associate a log file pointer with each thread. */    
static pthread_key_t thread_log_key;  

/* Write MESSAGE to the log file for the current thread. */    
void write_to_thread_log (const char* message)    {  
    FILE* thread_log = (FILE*) pthread_getspecific (thread_log_key);   
    fprintf (thread_log, %s\n, message);  
}  

/* Close the log file pointer THREAD_LOG. */    
void close_thread_log (void* thread_log)  {  
    fclose ((FILE*) thread_log);      
}  

void* thread_function (void* args)    {  
    char thread_log_filename[20];    
    FILE* thread_log;  

    /* Generate the filename for this thread’s log file. */    
    sprintf (thread_log_filename, thread%d.log, (int) pthread_self ());  

    /* Open the log file. */    
    thread_log = fopen (thread_log_filename, w);  

    /* Store the file pointer in thread-specific data under thread_log_key. */    
    pthread_setspecific (thread_log_key, thread_log);  

    write_to_thread_log (Thread starting.);  

    /* Do work here... */    
    return NULL;  
}  

int main ()    {    
    int i;    
    pthread_t threads[5];  

    /* Create a key to associate thread log file pointers in  
       thread-specific data. Use close_thread_log to clean up the file  
       pointers. */    
    pthread_key_create (&thread_log_key, close_thread_log);  

    /* Create threads to do the work. */    
    for (i = 0; i < 5; ++i)  
        pthread_create (&(threads[i]), NULL, thread_function, NULL);  

    /* Wait for all threads to finish. */    
    for (i = 0; i < 5; ++i)    
        pthread_join (threads[i], NULL);  
    return 0;    
}    

线程和exec()

当在线程中调用exec()时,该线程被完全的被替代,线程ID不确定。除了被替代的线程,其他线程都被销毁。线程的thread-specific data销毁函数和清除函数都不会被调用。所有进程的互斥量和条件变量消失。

线程和fork()

当在多线程进程中调用fork(),只有调用fork()的线程被复制到子进程

虽然只有调用fork()的线程被复制到子进程,但是子进程的全局变量,互斥量,条件变量的状态都将和在父进程中的一样。也就是说,如果它在父进程中被锁住,则它在子进程中也是被锁住的。

thread-specific data的销毁函数和清除函数都不会被调用。在多线程中调用fork()可能会引起内存泄露。比如在其他线程中创建的thread-specific data,在子进程中将没有指针来存取这些数据,造成内存泄露。

因为以上这些问题,在线程中调用fork()的后,我们通常都会在子进程中调用exec()。因为exec()能让父进程中的所有互斥量,条件变量(pthread objects)在子进程中统统消失(用新数据覆盖所有的内存)

应该避免在一个多线程的程序中使用fork

线程取消选项

可取消状态属性可以是PTHREAD_CANCEL_ENABLE和PTHREAD_CANCEL_DISABLE,线程可以通过调用pthread_setcancelstate修改它的可取消状态。

#include<pthread.h>  
int pthread_setcancelstate(int state, int *oldstate); //成功则返回0,否则返回错误编号。  

pthread_setcancelstate把当前可取消状态设置为state,把原来的可取消状态存放在oldstate指向的内存单元中,这两步是原子操作。

pthread_cancel并不等待线程终止,在默认情况下,线程在取消请求发出以后还是继续运行,直到线程到达某个取消点

取消点是线程检查是否被取消并按照请求进行动作的一个位置。POSIX.1保证在下表中列出的任何函数,取消点都会出现。

下表POSIX.1定义的可选取消点:

线程启动是默认的可取消状态是PTHREAD_CANCEL_ENABLE。当状态设为PTHREAD_CANCEL_DISABLE时,对pthread_cancel的调用并不会杀死线程,相反,取消请求对这个线程来说处于未决状态。当取消状态再次变成PTHREAD_CANCEL_ENABLE时,线程将在下一个取消点上对所有未决的取消请求进行处理。

如果应用程序在很长一段时间内都不会调用到上面的函数,那么可以调用pthread_testcancel函数在程序中自己添加取消点

#include<pthread.h>  
void pthread_testcancel(void); 

调用pthread_testcancel时,如果有个取消请求正处于未决状态,而且取消并没有设置为无效,那么线程就会被取消。但是如果取消被置成无效,pthread_testcancel调用就没有任何效果。

上述述的默认取消类型也称为延迟取消,调用pthread_cancel以后,在线程到达取消点之前,并不会出现真正的取消,可以通过调用pthread_setcanceltype来修改取消类型。

#include<pthread.h>  
int pthread_setcanceltype(int type, int *oldtype); //成功则返回0,否则返回错误编号。  

type参数可以是PTHERAD_CANCEL_DEFERRED(延迟取消)或PTHREAD_CANCEL_ASYNCHRONOUS(异步取消),

使用异步取消时,线程可以在任何时间取消,而不是非要等到遇到取消点才能被取消

线程锁

https://bingoex.github.io/2015/12/01/linux-lock/


如果文章对您有帮助,欢迎扫描下方二维码赞助(一分也是爱噢),谢谢

Search

    一分也是爱噢 一分也是爱

    目录