明天不整 GO 语言,咱们来分享一下以前写的 C 代码,来看看 互斥锁,自旋锁和原子操作的 demo
互斥锁
临界区资源曾经被1个线程占用,另一个线程过去拜访临界资源的时候,会被CPU切换线程,不让运行起初的这个线程
实用于 锁住的内容多,(例如红黑数的减少节点操作),切换线程的代价小于期待的代价
自旋锁
临界区资源曾经被1个线程占用,另一个线程过去拜访临界资源的时候,相当于是一个 while(1)
一直的查看这个资源是否可用,如果可用,就进去拜访临界资源,如果不可用,则持续循环拜访
实用于锁住的内容少,(例如就执行++操作),切换线程的代价大于期待的代价
原子操作
执行的操作齐全不可分割,要么全副胜利,要么全副失败
最好的形式就是实用原子操作
实操
需要场景:
1、用10个线程别离对 count 加 100000 次, 看看后果是否是 10*100000
- main 函数中创立 10 个线程
- 线程函数中调用 inc 做数据的减少
- 别离应用 互斥锁,自旋锁,和原子操作,来进行管制
#include <stdio.h>#include <pthread.h>#include <unistd.h>#define PTHREAD_NUM 10#define INFO printfpthread_mutex_t mutex;pthread_spinlock_t spin;int inc(int *v,int add){ int old; //汇编,做一个原子操作 __asm__ volatile( "lock;xaddl %2, %1;" :"=a" (old) :"m"(*v),"a"(add) :"cc","memory" ); return old;}void * thread_callback(void *arg){ int *count = (int *)arg; int i = 100000; while(i--) { #if 0//互斥锁 pthread_mutex_lock(&mutex); (*count)++; pthread_mutex_unlock(&mutex); #elif 0//自旋锁 pthread_spin_lock(&spin); (*count)++; pthread_spin_unlock(&spin); #else//原子操作 inc(count,1); #endif usleep(1); }}int main(){ pthread_t thread[PTHREAD_NUM] = {0}; pthread_mutex_init(&mutex,NULL); pthread_spin_init(&spin,0); int count = 0; for(int i = 0;i<PTHREAD_NUM;i++){ pthread_create(&thread[i],NULL,thread_callback,&count); } for(int i = 0;i<100;i++) { INFO("count == %d\n",count); sleep(1); } return 0;}
如上代码还是很简略的,感兴趣的 xdm 能够自行运行,管制本人应用互斥锁,自旋锁或者是原子操作看看成果进行比照一下
2、mutex、lock、atomic 性能比照
思路还是和下面的思路类型,咱们能够通过上面的代码来理论初步看看 mutex、lock、atomic 各自的性能
//并发//互斥锁mutex// 如果获取不到资源会让出cpu// 应用场景// 共享区域执行的内容较多的状况//自旋锁spinlock// 如果获取不到资源,会原地自旋,忙等// 应用场景// 共享区域执行的内容较少的状况//原子操作// 不可分割// 应用场景// 做简略++、--操作//#include <stdio.h>#include <pthread.h>#include <unistd.h>#include <time.h>#define MAX_PTHREAD 2#define LOOP_LEN 1000000000#define LOOP_ADD 10000int count = 0;pthread_mutex_t mutex;pthread_spinlock_t spin;typedef void *(*functhread)(void *arg);void do_add(int num){ int sum = 0; for(int i = 0;i<num;i++) { sum +=i; }}int atomic_add(int *v,int add){ int old; __asm__ volatile( "lock;xaddl %2, %1;" :"=a" (old) :"m"(*v),"a"(add) :"cc","memory" ); return old;}void * atomicthread(void *arg){ for(int i = 0;i<LOOP_LEN;i++){ atomic_add(&count,1); }}void * spinthread(void *arg){ for(int i = 0;i<LOOP_LEN;i++){ pthread_spin_lock(&spin); count++; //do_add(LOOP_ADD); pthread_spin_unlock(&spin); }}void * mutexthread(void *arg){ for(int i = 0;i<LOOP_LEN;i++){ pthread_mutex_lock(&mutex); count++; //do_add(LOOP_ADD); pthread_mutex_unlock(&mutex); }}int test_lock(functhread thre,void * arg){ clock_t start = clock(); pthread_t tid[MAX_PTHREAD] = {0}; for(int i = 0;i<MAX_PTHREAD;i++) { //创立线程 int ret = pthread_create(&tid[i],NULL,thre,NULL); if(0 != ret) { printf("pthread create rror\n"); return -1; } } for(int i = 0;i<MAX_PTHREAD;i++){//回收线程 pthread_join(tid[i],NULL); } clock_t end = clock(); //printf("start -- %ld\n",start); //printf("end -- %ld\n",end); //printf("CLOCKS_PER_SEC -- %ld\n",CLOCKS_PER_SEC); printf("spec lock is -- %ld\n",(end - start)/CLOCKS_PER_SEC);}int main(){ pthread_mutex_init(&mutex,NULL); pthread_spin_init(&spin,0);//测试spin count = 0; printf("use spin ------ \n"); test_lock(spinthread,NULL); printf("count == %d\n",count);//测试mutex count = 0; printf("use mutex ------ \n"); test_lock(mutexthread,NULL); printf("count == %d\n",count);//测试atomic count = 0; printf("use automic ------ \n"); test_lock(atomicthread,NULL); printf("count == %d\n",count); return 0;}
后果
通过上述后果,咱们能够看到,加互斥锁,自旋锁,原子操作,数据都能如我所愿的累加正确,在工夫下面他们还是有肯定的差别:
自旋锁 和 互斥锁 在此处的案例性能差不多,然而原子操作绝对就快了很多
欢送点赞,关注,珍藏
敌人们,你的反对和激励,是我保持分享,提高质量的能源
好了,本次就到这里
技术是凋谢的,咱们的心态,更应是凋谢的。拥抱变动,背阴而生,致力向前行。
我是阿兵云原生,欢送点赞关注珍藏,下次见~