Linux 线程锁

51 阅读 0 评论 34 点赞

我是靠谱客的博主英俊天空，最近开发中收集的这篇文章主要介绍Linux 线程锁，觉得挺不错的，现在分享给大家，希望可以做个参考。

概述

两个线程分别计算从1加到100，并且把结果都存储在count变量中。因此为了保证数据的线程安全，在对count值进行写操作时要加锁。加锁可以通过

pthread_mutex_lock()

和

pthread_mutex_unlock()

两个函数来实现加锁与释放锁。

但是实际应用中为了代码简洁以及防止程序员漏掉unlock，所以通过一个线程锁对象来实现线程锁的自释放。

ThreadLock构造函数执行时对外部的锁对象加锁，对象生命周期结束后执行析构函数，释放外部锁对象。

class ThreadLock
{
private:
pthread_mutex_t* mutexPtr;
public:
explicit inline ThreadLock(pthread_mutex_t *pm):mutexPtr(pm)//explicit 抑制隐式转换，inline加入符号表提高函数调用效率
{
//printf("lock of threadid:%dn",pthread_self());//放在这里，打印出来的信息不准
pthread_mutex_lock(mutexPtr);
printf("lock of threadid:%dn",pthread_self());
}
inline ~ThreadLock()
{
printf("unlock of threadid:%dn",pthread_self());
pthread_mutex_unlock(mutexPtr);
}
};

/*************************************************************************

> File Name: threadsync.c
> Author: chenhui
> Mail: *********
> Created Time: 2016年02月29日 21:53:40
************************************************************************/

#include <stdio.h>
#include <pthread.h>
#include <unistd.h>
#include <stdlib.h>
#include "threadLock.h"

int count=0;

pthread_mutex_t count_mutex=PTHREAD_MUTEX_INITIALIZER;
void *addNum(void*)//.c文件时没加void*,可以编译运行。.cpp文件时编译不过（pthread_create(,,addNum,)）提示类型转换无效
{
int i=1;
for(;i<=100;i++)
{
//pthread_mutex_lock(&count_mutex);//线程锁

ThreadLock lock(&count_mutex);
count+=i;
printf("count:%d,of thread id:%dn",count,pthread_self());

//pthread_mutex_unlock(&count_mutex);
}
}

int main()
{
pthread_t p1,p2;
pthread_create(&p1,NULL,addNum,NULL);
pthread_create(&p2,NULL,addNum,NULL);

pthread_join(p1,NULL);
pthread_join(p2,NULL);

return 0;
}
/*
* pthread_join使一个线程等待另一个线程结束。代码中如果没有pthread_join主线程会很快结束从而使整个进程结束,
* 从而使创建的线程没有机会开始执行就结束。

* */

threadLock.h

#ifndef THREAD_LOCK
#define THREAD_LOCK

#include <stdlib.h>
#include <pthread.h>
#include <unistd.h>
#include <stdio.h>

class ThreadLock
{
private:
pthread_mutex_t* mutexPtr;
public:
explicit inline ThreadLock(pthread_mutex_t *pm):mutexPtr(pm)//explicit 抑制隐式转换，inline加入符号表提高函数调用效率
{
//printf("lock of threadid:%dn",pthread_self());//放在这里，打印出来的信息不准
pthread_mutex_lock(mutexPtr);
printf("lock of threadid:%dn",pthread_self());
}
inline ~ThreadLock()
{
printf("unlock of threadid:%dn",pthread_self());
pthread_mutex_unlock(mutexPtr);
}
};
//ThreadLock lock=&mutex;//如果不加explicit，可以这样写。

#endif