std::make_shared源码
时间: 2023-12-21 16:06:13 浏览: 77
```cpp
template<class T, class... Args>
shared_ptr<T> make_shared(Args&&... args)
{
return shared_ptr<T>(new T(std::forward<Args>(args)...));
}
```
`std::make_shared`是一个模板函数,用于创建一个指定类型的`std::shared_ptr`对象。它接受任意数量的参数,并使用这些参数来构造指定类型的对象。在内部,`std::make_shared`通过调用`new`运算符来分配内存,并使用传递的参数来构造对象。然后,它将返回一个指向该对象的`std::shared_ptr`。
使用`std::make_shared`的好处是它可以在一次内存分配中同时分配对象和控制块(用于跟踪引用计数等信息)。这样可以提高性能并减少内存碎片。此外,`std::make_shared`还可以确保异常安全,因为它在内存分配和对象构造之间没有中间状态。
相关问题
std::shared_ptr<char> buffer_672p 获取大小
根据引用中的代码示例,可以看出std::shared_ptr<char> buffer_672p是一个指向char类型的共享指针。然而,从提供的信息中没有明确指出buffer_672p的大小。要获取buffer_672p的大小,需要进一步查看代码或者提供更多的信息。<span class="em">1</span><span class="em">2</span><span class="em">3</span>
#### 引用[.reference_title]
- *1* *2* [std::make_shared源码剖析](https://blog.csdn.net/kupe87826/article/details/120233647)[target="_blank" data-report-click={"spm":"1018.2226.3001.9630","extra":{"utm_source":"vip_chatgpt_common_search_pc_result","utm_medium":"distribute.pc_search_result.none-task-cask-2~all~insert_cask~default-1-null.142^v93^chatsearchT3_1"}}] [.reference_item style="max-width: 50%"]
- *3* [std::shared_ptr(基础、仿写、安全性)](https://blog.csdn.net/weixin_48560325/article/details/128032383)[target="_blank" data-report-click={"spm":"1018.2226.3001.9630","extra":{"utm_source":"vip_chatgpt_common_search_pc_result","utm_medium":"distribute.pc_search_result.none-task-cask-2~all~insert_cask~default-1-null.142^v93^chatsearchT3_1"}}] [.reference_item style="max-width: 50%"]
[ .reference_list ]
C++ 线程池 源码实现 和注释
C++ 线程池的源码实现和注释如下:
```cpp
#include <iostream>
#include <queue>
#include <thread>
#include <atomic>
#include <vector>
#include <functional>
class ThreadPool {
public:
ThreadPool(size_t numThreads) : stop(false) {
for (size_t i = 0; i < numThreads; ++i) {
workers.emplace_back(
[this]() {
while (true) {
std::function<void()> task;
{
std::unique_lock<std::mutex> lock(this->queueMutex);
this->condition.wait(lock,
[this]() { return this->stop || !this->tasks.empty(); });
if (this->stop && this->tasks.empty()) {
return;
}
task = std::move(this->tasks.front());
this->tasks.pop();
}
task();
}
}
);
}
}
template<class F, class... Args>
void enqueue(F&& f, Args&&... args) {
using ReturnType = typename std::result_of<F(Args...)>::type;
auto task = std::make_shared<std::packaged_task<ReturnType()>>(
std::bind(std::forward<F>(f), std::forward<Args>(args)...)
);
std::future<ReturnType> result = task->get_future();
{
std::unique_lock<std::mutex> lock(queueMutex);
// stop为true时不允许提交新的任务
if (stop)
throw std::runtime_error("enqueue on stopped ThreadPool");
tasks.emplace([task]() { (*task)(); });
}
condition.notify_one();
return result;
}
~ThreadPool() {
{
std::unique_lock<std::mutex> lock(queueMutex);
stop = true;
}
condition.notify_all();
for (std::thread& worker : workers) {
worker.join();
}
}
private:
std::vector<std::thread> workers;
std::queue<std::function<void()>> tasks;
std::mutex queueMutex;
std::condition_variable condition;
std::atomic<bool> stop;
};
```
注释解释:
1. `ThreadPool` 类是一个线程池,用于创建和管理线程。
2. 构造函数 `ThreadPool(size_t numThreads)` 接收一个参数 `numThreads`,表示线程池中的线程数量。
3. `enqueue` 函数用于将任务添加到线程池中执行。
4. 线程池中的每个线程都会不断从任务队列中获取任务并执行,直到线程池被销毁或停止。
5. `stop` 是一个原子布尔值,用于表示线程池是否停止。
6. `tasks` 是一个队列,用于存储待执行的任务。
7. `queueMutex` 是一个互斥锁,用于保护任务队列的操作。
8. `condition` 是一个条件变量,用于线程间的同步和通信。
阅读全文