拼多多服务器开发.
1.线程池大小如何考虑的,如果有线程阻塞了怎么办?
大小考虑参见
A.https://blog.csdn.net/bian_qing_quan11/article/details/78030016
B.https://blog.csdn.net/byteArr/article/details/96590084
如果有线程阻塞了怎么办?
胡编:考虑阻塞的原因,如果是互斥锁等原因,只能让线程等待,或者线程有一个时间的属性,超时自动析构,释放资源
2.讲一下线程池的分配策略
参考https://www.imooc.com/article/34450
3.C++11对并发操作的支持
创建线程:std::thread t1(function_1)
释放线程 t1.join()和t1.detach()
两者区别在于join()方法是主线程会一直阻塞着,直到子线程完成,join()函数的另一个任务是回收该线程中使用的资源。
t1.detach()将t1线程放在后台运行,所有权和控制权被转交给C++运行时库,以确保与线程相关联的资源在线程退出后能被正确的回收。这种被分离的线程被称为守护线程(daemon threads)。线程被分离之后,即使该线程对象被析构了,线程还是能够在后台运行,只是由于对象被析构了,主线程不能够通过对象名与这个线程进行通信。
互斥锁 mutex头文件
std::mutex mu;
mu.lock();
mu.unlock();
std::lock_guard<std::mutex> guard(mu);//保证析构的时候能够释放锁
注意:子进程传主进程需要通过引用传递或者通过单例模式保证线程安全。
1.不要提供函数让用户获取资源。
2.不要资源传递给用户的函数。
接口设计也存在竞争条件,导致线程不安全。
死锁
解决方法
1.采用严格规定上锁顺序,只不过实现方式不同。
可以比较mutex的地址,每次都先锁地址小的或者使用层次锁,将互斥锁包装一下,给锁定义一个层次的属性,每次按层次由高到低的顺序上锁
2.采用std::lock()能够保证将多个互斥锁同时上锁,同时std::lock_guard<std::mutex> guard(_mu2, std::adopt_lock);std::adopt_lock说明不需要上锁,
3.尽量只对一个互斥锁进行上锁
4.不要在互斥锁保护的区域使用用户自定义的代码,因为用户的代码可能操作了其他的互斥锁。
细粒度锁
修改方法是使用unique_lock。它提供了lock()和unlock()接口,能记录现在处于上锁还是没上锁状态,在析构的时候,会根据当前状态来决定是否要进行解锁(lock_guard就一定会解锁)
std::unique_lock<std::mutex> guard(_mu, std::defer_lock);
std::defer_lock表示预先不需要上锁
条件变量
条件变量适合于生产者消费者模型,用于线程同步
#include <condition_variable>
std::condition_variable cond;
void function_1() {
int count = 10;
while (count > 0) {
std::unique_lock<std::mutex> locker(mu);
q.push_front(count);
locker.unlock();
cond.notify_one(); // Notify one waiting thread, if there is one.
std::this_thread::sleep_for(std::chrono::seconds(1));
count--;
}
}
void function_2() {
int data = 0;
while ( data != 1) {
std::unique_lock<std::mutex> locker(mu);
while(q.empty())
cond.wait(locker); // Unlock mu and wait to be notified
data = q.back();
q.pop_back();
locker.unlock();
std::cout << "t2 got a value from t1: " << data << std::endl;
}
}
cond.wait 阻塞当前条件变量
cond.notify_one(); 唤醒一个处于wait状态的条件变量
cond.notify_all();唤醒所有处于wait状态的条件变量
理解线程类的构造函数
std::thread类的构造函数是使用可变参数模板实现的,也就是说,可以传递任意个参数,第一个参数是线程的入口函数,而后面的若干个参数是该函数的参数。
一般都是值传递,而如果可以想真正传引用,可以在调用线程类构造函数的时候,用std::ref()包装一下。如下面修改后的代码:
std::thread t1(f, std::ref(m));
线程对象只能移动不可复制,移动的意思是,将线程的所有权在std::thread实例间进行转移。
unique_lock和lock_guard都不能复制,lock_guard不能移动,但是unique_lock可以!
讲一下AtomicInteger的实现
STL里有线程安全的容器吗,如何实现线程安全的容器
没有,就用消费者生产者模型设计线程安全的队列
可重入锁
二者唯一的区别是,同一个线程可以多次获取同一个递归锁,不会产生死锁。而如果一个线程多次获取同一个非递归锁,则会产生死锁。
设计可重入锁
用个信号量来标记