异步化方案:最近做项目,需要调用的一些服务,但是这个服务本身和主线程没有什么关联,所以这时候我们可以将其异步化,从而提升整体的性能。
然后我是怎么做的呢?
第一步,肯定是要开启线程,初始化 mutex
- pthread_mutex_t locker;
- pthread_cond_t cond;
- pthread_t thread;
- queue m_qtransfer; //队列作为缓冲区pthread_mutex_init(&locker, NULL);//初始化锁pthread_cond_init(&cond, NULL);//初始化条件,它的作用后续会讲到ret = pthread_create(&thread, NULL, ProcessCycle, reinterpret_cast(i));//创建线程
我们在生产的时候,怎么做呢?
- pthread_mutex_lock( & locker[job_kind]);
- m_qtransfer.push(job);
- pthread_cond_signal( & cond[job_kind]);
- pthread_mutex_unlock( & locker[job_kind]);
我们在消费的时候怎么做呢?
- pthread_mutex_lock( & transfer - >locker);
- while (!transfer - >thread_exit) {
- if (transfer - >m_qtransfer.empty()) {
- pthread_cond_wait( & transfer - >cond, &transfer - >locker);
- continue;
- }...取出对队列里的任务pthread_mutex_unlock( & transfer - >locker);...执行任务pthread_mutex_lock( & transfer - >locker);}
整个操作的核心在于 pthread_cond_wait 和 pthread_cond_signal 那句:
子线程上来的时候,先锁住缓冲区,如果缓冲区为空,就执行 pthread_cond_wait,
这条语句相当于下面两句话形成原子操作
- unlock(locker)sleep();
然后 pthread_cond_signal 执行之后唤醒子线程进行操作了等于
- wake 子线程lock(locker)
子线程就锁住缓冲区进行操作了。
其实这个设计的主要思路是,父线程驱动子线程。可以多考虑考虑,这种情况不会死锁。
就爱阅读 www.92to.com 网友整理上传, 为您提供最全的知识大全, 期待您的分享,转载请注明出处。
来源: http://www.92to.com/bangong/2017/03-03/18007792.html