。

抢票为什么会抢到负数#xff1a;假设当票数为1时#xff0c;此时四个进程的判断条件tickets都大于0#xff0c;都会进入抢票操作#xff0c;第一个进程抢完票以后tickets0并写回内存#xff0c;第二个进程再…一、多线程不加线程互斥可能会引发的问题

下面是一个抢标逻辑。

抢票为什么会抢到负数假设当票数为1时此时四个进程的判断条件tickets都大于0都会进入抢票操作第一个进程抢完票以后tickets0并写回内存第二个进程再从内存中读取tickets的值时此时tickets已经为0再做--就变成了-1tickets为负数就是这么来的。

也就是说多线程代码如果不对共享资源做保护可能会有并发问题。

二、互斥锁

pthread_mutex_init(pthread_mutex_t

*restrict

pthread_mutex_destroy(pthread_mutex_t

*mutex)

pthread_mutex_lock(pthread_mutex_t

*mutex);

pthread_mutex_unlock(pthread_mutex_t

*mutex);

pthread_mutex_lock函数如果申请锁成功就会继续向后运行如果申请失败该函数就会阻塞不允许继续向后运行。

movb

$0%al表示将0存入%al寄存器中%al是累加寄存器AX的低8位部分可以独立作为8位寄存器使用。

xchgb

mutex表示交换%al寄存器中的值和内存mutex中的值如果内存mutex中的值原本是1交换完则表示得到锁否则挂起等待。

unlock中将1存入mutex内存中表示归还锁。

这样无论如何得到1的线程始终只会有一个也就做到了线程互斥。

//thread.hpp

Excute(){_func(_data);}public:Thread(func_tT

func,

Detach(){if(!_stop){pthread_detach(_tid);}}void

Join(){if(!_stop){pthread_join(_tid,

name(){return

mutex):_mutex(mutex){pthread_mutex_lock(_mutex);}~LockGuard(){pthread_mutex_unlock(_mutex);}};#endif

//testThread.cc

所有的线程最后都会引用同一个全局的g_ticketsstd::string

_name;int

mutex;pthread_mutex_init(mutex,nullptr);std::vectorThreadThreadData*

inum;

mutex);threads.emplace_back(route,

td,

name);datas.emplace_back(td);}//

一批线程for

threads){thread.Join();}sleep(1);//

输出统计数据for

data;}pthread_mutex_destroy(mutex);return