cpp-queue

发表于 更新于 分类于 阅读次数： 本文字数： 316 阅读时长 ≈ 1 分钟

所有函数都不是线程安全的

// 发送队列锁
std::mutex m_mutex_write;
// 发送队列
std::queue< std::pair<std::shared_ptr<unsigned char[]>, DWORD> > m_queWrite;


std::shared_ptr<BYTE[]> spBuf(new BYTE[length]);
memcpy(spBuf.get(), data, length);

std::lock_guard<std::mutex> lock(m_mutex_write);
m_queWrite.push(make_pair(spBuf,length));