// 多线程示例
#include <iostream>
#include <thread>
#include <queue>
#include <mutex>
#include <condition_variable>
// 队列大小
int buffer_size = 10;
// 定义了一个全局变量代表队列
std::queue<int> buffer;
// 互斥锁保证生产者和消费者的不能同时访问缓冲区
std::mutex buffer_mutex;
// 条件变量: 未满
std::condition_variable not_full;
// 条件变量: 未空
std::condition_variable not_empty;
void produce()
{
// 生产者
for (int i = 1; i <= 20; i++)
{
// 使用互斥锁
std::unique_lock<std::mutex> lock(buffer_mutex);
// 队列满时阻塞生产者
not_full.wait(lock, []
{ return buffer.size() < buffer_size; });
// 生产产品
buffer.push(i);
std::cout << "生产 " << i << std::endl;
// 唤醒消费者
not_empty.notify_one();
}
}
void consume()
{
// 消费者
while (true)
{
// 使用互斥锁
std::unique_lock<std::mutex> lock(buffer_mutex);
// 队列空时阻塞消费者
not_empty.wait(lock, []
{ return !buffer.empty(); });
// 消费产品
int val = buffer.front();
buffer.pop();
std::cout << "消费 " << val << std::endl;
// 唤醒生产者
not_full.notify_one();
if (val == 20)
{
break;
}
}
}
int main()
{
// 多线程
std::thread producer(produce);
std::thread consumer(consume);
producer.join();
consumer.join();
return 0;
}
// g++ main.cpp -std=c++14 -pthread
/usr/bin/ld: /tmp/ccXbL3AS.o: in function `std::thread::thread<void (&)(), , void>(void (&)())':
main.cpp:(.text._ZNSt6threadC2IRFvvEJEvEEOT_DpOT0_[_ZNSt6threadC5IRFvvEJEvEEOT_DpOT0_]+0x30): undefined reference to `pthread_create'
/usr/bin/ld: main.cpp:(.text._ZNSt6threadC2IRFvvEJEvEEOT_DpOT0_[_ZNSt6threadC5IRFvvEJEvEEOT_DpOT0_]+0x34): undefined reference to `pthread_create'
collect2: error: ld returned 1 exit status
g++ main.cpp -std=c++14 -pthread
由于pthread库不是Linux系统默认的库,连接时需要使用库libpthread.a,所以在使用pthread_create创建线程时,在编译中要加-lpthread参数