多线程是游戏开发必备知识。无论是操作系统的互斥锁还是网络通信的资源管理,多线程并发是永远要熟练其使用的知识。
例子1:
#include "stdafx.h" #include<atomic> #include <thread> #include <iostream> std::atomic<int> a(10); std::atomic_llong total = {0};//定义为原子操作,保证多线程互斥访问 void funCount(int) { for (long long i = 0; i <100000000LL; i++) { total+=i; } } int _tmain(int argc, _TCHAR* argv[]) { std::thread t1(funCount,0);//线程创建后由操作系统启动和运行,具有不可控性 std::thread t2(funCount,0); t1.join();//join的运行依赖于主线程,当主线程退出时会强制关闭依附于它的子线程,并执行资源回收。调用即主线程被挂起等待join入的子线程运行完再执行新的线程,也就是说线程t2属性的更改,在于t1执行完成之后 t2.join();//detach的区别在独立于主线程,与主线程同级,就面临一个问题:当主线程退出时,要保证detach的线程不在访问主线程的资源,否则会报错。 //t2.detach(); ; std::cout<<__FUNCTION__<<":"<<total<<"\t"<<a.is_lock_free()<<std::endl; <span style="white-space:pre"> </span>
<span style="white-space:pre"> </span>//确认线程结束,输入的是120,线程不在对total进行读取 total.store(120); std::cout<<__FUNCTION__<<":"<<total<<"\t"<<a.is_lock_free()<<std::endl; return 0; }
为了验证t2的更改在属性线程t1执行完成之后,有如下例子:
int _tmain(int argc, _TCHAR* argv[]) { std::thread t1(funCount,0); std::cout<<__FUNCTION__<<":"<<total<<"\t"<<a.is_lock_free()<<std::endl; std::thread t2(funCount,0); std::cout<<__FUNCTION__<<":"<<total<<"\t"<<a.is_lock_free()<<std::endl; t1.join(); //t2.detach(); ; std::cout<<__FUNCTION__<<":"<<total<<"\t"<<a.is_lock_free()<<std::endl; t2.detach(); //total.store(120);//访问当前值试试,形成互斥 std::cout<<__FUNCTION__<<":"<<total<<"\t"<<a.is_lock_free()<<std::endl; std::cout<<__FUNCTION__<<":"<<total<<"\t"<<a.is_lock_free()<<std::endl; return 0; }因为t2还处于默认状态。
什么是默认状态:
在任何一个时间点上,线程是可结合的(joinable),或者是分离的(detached)。一个可结合的线程能够被其他线程收回其资源和杀死;在被其他线程回收之前,它的存储器资源(如栈)是不释放的。相反,一个分离的线程是不能被其他线程回收或杀死的,它的存储器资源在它终止时由系统自动释放。
线程的分离状态决定一个线程以什么样的方式来终止自己。在默认情况下线程是非分离状态的,这种情况下,原有的线程等待创建的线程结束。只有当pthread_join()函数返回时,创建的线程才算终止,才能释放自己占用的系统资源。而分离线程不是这样子的,它没有被其他的线程所等待,自己运行结束了,线程也就终止了,马上释放系统资源。程序员应该根据自己的需要,选择适当的分离状态。所以如果我们在创建线程时就知道不需要了解线程的终止状态,则可以pthread_attr_t结构中的detachstate线程属性,让线程以分离状态启动。
基于此,如果线程t2实现了睡眠的话,就会明显出现下面的结果(如果主线程结束的比t2早,而t2仍未结束计算,则可能出现中断。如下的代码结束后没有出现中断,暂时模拟不出中断待续)
难道和使用了原子类型有关,不对,只有一个可能就是t1回调和main执行的过程中,它已经结束了。
int _tmain(int argc, _TCHAR* argv[]) { std::thread t1(funCount,0); std::cout<<__FUNCTION__<<":"<<total<<"\t"<<total.is_lock_free()<<std::endl; std::cout<<__FUNCTION__<<":"<<total<<"\t"<<total.is_lock_free()<<std::endl; t1.detach(); // ; std::cout<<__FUNCTION__<<":"<<total<<"\t"<<total.is_lock_free()<<std::endl; //total.store(120);//访问当前值试试,形成互斥 std::cout<<__FUNCTION__<<":"<<total<<"\t"<<total.is_lock_free()<<std::endl; std::cout<<__FUNCTION__<<":"<<total<<"\t"<<total.is_lock_free()<<std::endl; std::thread t2(funCount,0);t2.detach(); return 0; }
原文地址:http://blog.csdn.net/jingzhewangzi/article/details/41294933