多线程互斥抢票问题及其解决方案

在多线程编程中，处理共享资源时可能会遇到互斥问题。让我们深入探讨一下这个问题，并通过一个具体的抢票场景来理解和解决它。

多线程抢票问题

假设我们有1000张火车票，四个线程同时在抢票。代码如下：

#include "Thread.hpp"
int tickets = 1000; // 票数
void thread_run(void args) {
string name = static_cast(args);
while(true) {
if(tickets > 0) {
usleep(1234); // 1秒=1000毫秒=1000000微秒
cout << name << "抢到票, 票数为: " << tickets-- << endl;
} else {
break;
}
}
return nullptr;
}
int main() {
unique_ptr thread1(new Thread(thread_run, (void)"user1",1));
unique_ptr thread2(new Thread(thread_run, (void)"user2",2));
unique_ptr thread3(new Thread(thread_run, (void)"user3",3));
unique_ptr thread4(new Thread(thread_run, (void)"user4",4));
thread1->join();
thread2->join();
thread3->join();
thread4->join();
return 0;
}

问题分析

运行上述代码时，可能会看到票数出现0、-1、-2等负数的情况。这是由于多线程并发访问共享资源（票数）时，导致的数据竞争和不一致性。

多线程交叉执行的本质是调度器频繁切换线程。线程切换可能在以下几种情况发生：

1. 时间片用完
2. 更高优先级线程就绪
3. 线程进入等待状态

线程在从内核态切换到用户态时，会检测调度状态并可能进行线程切换。

原因解析

在读取和修改共享变量ticket的过程中，由于线程切换，可能会发生以下情况：

1. 读取到寄存器：线程1读取票数到CPU寄存器中。
2. 判断和修改：如果在判断和修改之间发生线程切换，其他线程也可能读取到同样的票数，导致多个线程同时减少票数。

例如，假设四个线程同时读取到票数为1，然后线程1将票数减少到0并打印，之后其他线程也尝试减少票数，导致票数变成负数。

解决方案：使用互斥锁

为了解决上述问题，我们可以使用互斥锁来确保在修改共享资源时，只有单个线程能够访问。

使用全局锁

#include "Thread.hpp"
int tickets = 1000; // 票数
pthread_mutex_t lock = PTHREAD_MUTEX_INITIALIZER; // 全局锁
void thread_run(void args) {
string name = static_cast(args);
while(true) {
pthread_mutex_lock(&lock); // 加锁
if(tickets > 0) {
usleep(1234); // 1秒=1000毫秒=1000000微秒
cout << name << "抢到票, 票数为: " << tickets-- << endl;
} else {
pthread_mutex_unlock(&lock);
break;
}
pthread_mutex_unlock(&lock); // 解锁
}
return nullptr;
}
int main() {
unique_ptr thread1(new Thread(thread_run, (void)"user1",1));
unique_ptr thread2(new Thread(thread_run, (void)"user2",2));
unique_ptr thread3(new Thread(thread_run, (void)"user3",3));
unique_ptr thread4(new Thread(thread_run, (void)"user4",4));
thread1->join();
thread2->join();
thread3->join();
thread4->join();
return 0;
}

使用全局锁后，线程在进入临界区时会加锁，离开时解锁，确保了票数的正确性。然而，由于线程串行执行，速度可能会变慢。

使用局部锁和线程数据

为了进一步优化，我们可以使用局部锁和线程数据来管理每个线程的抢票过程：

PHPB2B

PHP-B2B(原友邻b2b)是一套能够帮助用户,快速建立高效、多功能电子商务网站的php应用程序，本程序采用目前互联网上最流行的LAMP组合（Linux+Apache+Mysql+PHP)开发完成，同时利用Smarty模板技术实现了网站前台与后台的有效分离，用户可以快速地在此基础上开发自己的模板。 友邻php提供了电子商务应用最常见求购、供应、商品、公司库等模块,同时为企业用户提供了一个发布信

下载

#include "Thread.hpp"
int tickets = 1000; // 票数
class ThreadData {
public:
ThreadData(const string& threadname, pthread_mutex_t mutex_p) : _threadname(threadname), _mutex_p(mutex_p) {}
~ThreadData() {}
public:
string _threadname;
pthread_mutex_t _mutex_p;
};
void thread_run(void args) {
ThreadData p = static_cast>(args);
while(true) {
pthread_mutex_lock(p->_mutex_p); // 加锁
if(tickets > 0) {
usleep(1234); // 1秒=1000毫秒=1000000微秒
cout << p->_threadname << "抢到票, 票数为: " << tickets-- << endl;
} else {
pthread_mutex_unlock(p->_mutex_p);
break;
}
pthread_mutex_unlock(p->_mutex_p); // 解锁
usleep(1234); // 模拟抢完票形成一个订单
}
return nullptr;
}
int main() {
pthread_mutex_t lock;
pthread_mutex_init(&lock, nullptr); // 初始化锁
vector arr(4);
for(int i = 0; i < 4; i++) {
string thread_name = "user" + to_string(i + 1);
ThreadData* data = new ThreadData(thread_name, &lock);
pthread_create(&arr[i], nullptr, thread_run, data);
}
for(int i = 0; i < 4; i++) {
pthread_join(arr[i], nullptr);
}
return 0;
}

#pragma once
include 
include 
include 
include 
include 
include 
include 
include 
include 
using namespace std;
class Mutex {
public:
Mutex(pthread_mutex_t lock_p = nullptr) : _lock_p(lock_p) {}
void lock() { if(_lock_p) pthread_mutex_lock(_lock_p); }
void unlock() { if(_lock_p) pthread_mutex_unlock(_lock_p); }
~Mutex() {}
private:
pthread_mutex_t _lock_p;
};
class LockGuard {
public:
LockGuard(pthread_mutex_t *mutex) : _mutex(mutex) { _mutex.lock(); }
~LockGuard() { _mutex.unlock(); }
private:
Mutex _mutex;
};

#include "Thread.hpp"
include "Mutex.hpp"
int tickets = 1000; // 票数
class ThreadData {
public:
ThreadData(const string& threadname, pthread_mutex_t mutex_p) : _threadname(threadname), _mutex_p(mutex_p) {}
~ThreadData() {}
public:
string _threadname;
pthread_mutex_t _mutex_p;
};
void thread_run(void args) {
ThreadData p = static_cast>(args);
LockGuard lockGuard(p->_mutex_p); // 自动加锁解锁
while(true) {
if(tickets > 0) {
usleep(1234); // 1秒=1000毫秒=1000000微秒
cout << p->_threadname << "抢到票, 票数为: " << tickets-- << endl;
} else {
break;
}
}
return nullptr;
}
int main() {
pthread_mutex_t lock;
pthread_mutex_init(&lock, nullptr); // 初始化锁
vector arr(4);
for(int i = 0; i < 4; i++) {
string thread_name = "user" + to_string(i + 1);
ThreadData* data = new ThreadData(thread_name, &lock);
pthread_create(&arr[i], nullptr, thread_run, data);
}
for(int i = 0; i < 4; i++) {
pthread_join(arr[i], nullptr);
}
return 0;
}