认识死锁之生产者与消费者

上一篇博文：

https://blog.csdn.net/qq78442761/article/details/81276366

这里有一点：

CRITICAL_SECTION

此玩意，类似于互斥锁，是Windows平台提供的。

程序运行截图如下：

源码如下：

DeadLock.h

#pragma once#include <windows.h>
#include <iostream>
using namespace std;#define PRODUCERCNT 1   //生产者线程数量
#define CONSUMERCNT 1   //消费者线程数量
#define TOTALCNT PRODUCERCNT+CONSUMERCNTclass CDeadLock
{
public:CDeadLock();~CDeadLock();void CreateThread();void ToggleStatus();private:HANDLE hConsole;    //控制台句柄-改变控制台颜色输出bool m_bRunning;   //通知线程需要关闭int m_buffer; //关键数据-临界资源HANDLE threads[TOTALCNT];    //保存所有线程句柄static DWORD WINAPI producer(LPARAM lParam);  //生产者线程函数static DWORD WINAPI consumer(LPARAM lParam);   //消费者线程函数//生产和消费动作void produce();void consume();//Windows中提供了关键段，来协调CRITICAL_SECTION m_cs;
};

DeadLock.cpp

#include "DeadLock.h"CDeadLock::CDeadLock()
{hConsole = INVALID_HANDLE_VALUE;m_bRunning = false;m_buffer = 0;for (int i = 0; i < TOTALCNT; i++) {threads[i] = INVALID_HANDLE_VALUE;}hConsole = GetStdHandle(STD_OUTPUT_HANDLE);SetConsoleTitle(L"死锁");InitializeCriticalSection(&m_cs);
}CDeadLock::~CDeadLock()
{CloseHandle(hConsole);for (int i = 0; i < TOTALCNT; i++) {if (threads[i] != INVALID_HANDLE_VALUE) {CloseHandle(threads[i]);}}DeleteCriticalSection(&m_cs);
}void CDeadLock::CreateThread()
{int i = 0;m_bRunning = true;for (; i < PRODUCERCNT; i++) {threads[i] = ::CreateThread(0, 0, (LPTHREAD_START_ROUTINE)producer, this, 0, 0);}for (i = 0; i < CONSUMERCNT; i++) {threads[i] = ::CreateThread(0, 0, (LPTHREAD_START_ROUTINE)consumer, this, 0, 0);}
}void CDeadLock::ToggleStatus()
{m_bRunning = !m_bRunning;
}//生产者线程
DWORD WINAPI CDeadLock::producer(LPARAM lParam)
{CDeadLock *pThis = (CDeadLock*)lParam;cout << "producer threadID:" << GetCurrentThreadId() << endl;while (pThis->m_bRunning) {EnterCriticalSection(&pThis->m_cs);SetConsoleTextAttribute(pThis->hConsole, FOREGROUND_RED);pThis->produce();LeaveCriticalSection(&pThis->m_cs);}return 0;
}//消费者线程
DWORD WINAPI CDeadLock::consumer(LPARAM lParam)
{CDeadLock *pThis = (CDeadLock*)lParam;cout << "consumer threadID:" << GetCurrentThreadId() << endl;while (pThis->m_bRunning) {Sleep(10);EnterCriticalSection(&pThis->m_cs);SetConsoleTextAttribute(pThis->hConsole, FOREGROUND_GREEN);pThis->consume();LeaveCriticalSection(&pThis->m_cs);}return 0;
}void CDeadLock::produce()
{if (m_buffer > 200) {return;}//m_buffer++;__asm {mov         eax, dword ptr[this] //取this指针mov         ecx, dword ptr[eax + 8]   //取m_buffer的值，放在ecx寄存器里面//有可能执行到这一步，发送时间片到期的状态... 如果是10，那么这个10已经到了ecx寄存器里面，//这时候，消费者开始消耗了，消费者消耗完后应该是9，//但是，这个时候生产者的时间片又到了，此时把寄存器++，变成了11，这样就有问题了！！！add         ecx, 1                   //ECX++mov         edx, dword ptr[this]   //取this指针//此处可以直接这么优化 mov dword prt[eax+8],ecxmov         dword ptr[edx + 8], ecx //再放回去}printf("生产 - %d\n", m_buffer);
}void CDeadLock::consume()
{int data = m_buffer--;if (data) {printf("消费 - %d\n", data);}
}

main.cpp

#include "DeadLock.h"
#include <conio.h>void main() {cout << "main called!\n";CDeadLock deadLock;deadLock.CreateThread();   //注意，如果CreateThread两次，那么以前的线程就会被抛弃掉cout << "press any key to exit ... \n";while (true) {char cmd = _getch();if (cmd == 'q') {break;}else if (cmd == 'n') {deadLock.ToggleStatus();}}
}

认识死锁之生产者与消费者相关推荐

java多线程（同步和死锁，生产者和消费者问题）
首先我们来看看同步与死锁: 所谓死锁.这是A有banana,B有apple. A至B说:你把apple对我来说,,我会banana给你. B至A说:你把banana对我来说,,我会apple给你. 可 ...
操作系统之进程管理：12、生产者消费者问题和多级生产者多级消费者问题
12.生产者消费者问题和多级生产者多级消费者问题生产者消费者问题 1.问题描述 2.解题思路 3.解题过程 4.问题多级生产者多级消费者问题 1.问题描述 2.解题思路 3.解题过程: 4.问题 ...
JAVA笔记14__多线程共享数据（同步）/ 线程死锁 / 生产者与消费者应用案例 / 线程池...
/*** 多线程共享数据* 线程同步:多个线程在同一个时间段只能有一个线程执行其指定代码,其他线程要等待此线程完成之后才可以继续执行.* 多线程共享数据的安全问题,使用同步解决.* 线程同步两种方法: ...
菜鸟学习笔记：Java提升篇8（线程2——线程的基本信息、线程安全、死锁、生产者消费者模式、任务调度）
菜鸟学习笔记:Java提升篇8(线程2--线程的基本信息.线程安全.死锁.生产者消费者模式.任务调度) 线程的基本信息线程同步线程安全死锁生产者消费者模式任务调度(了解) 线程的基本信息 J ...
多线程：线程同步与死锁（卖票案例）、线程通信、生产者与消费者
卖票案例 5个窗口同时卖票: 使用Runnable接口,只创建了一个ticket1对象,5个线程共享此对象,实现了资源共享. public class ticket1 implements Runna ...
c/c++：线程同步（互斥锁、死锁、读写锁、条件变量、生产者和消费者模型、信号量）
目录 1. 概念 2. 互斥锁 3. 死锁 4. 读写锁 5. 条件变量 5.1 生产者和消费者模型 6. 信号量 1. 概念线程同步: > 当有一个线程在对内存进行操作时,其他线程都不可以对 ...
【Linux】生产者与消费者模型、信号量、死锁
目录死锁死锁的产生场景死锁的gdb分析 1.通过调试可执行程序来分析 2.通过调试正在运行的程序死锁的必要条件死锁的预防生产者与消费者模型 123规则应用场景及特点代码实现: 信号量 ...
6※、线程同步、同步锁、同步代码块的使用、同步锁释放的时机、ReentrantLock可重入锁、公平锁与非公平锁的区别、什么是死锁、线程间的通信（生产者和消费者模式）
线程锁 1.※线程的同步:(要确保对象锁是一致的) 1.未使用同步锁的抢票 2.使用了同步锁的抢票 3.线程-同步代码块的使用 4.同步方法和代码块的区别 5.同步锁释放的时机练习:多线程生产手机 ...
笔记-13-多线程 Thread方法线程安全生产者和消费者死锁和阻塞
1.实现多线程 1.1简单了解多线程[理解] 是指从软件或者硬件上实现多个线程并发执行的技术. 具有多线程能力的计算机因有硬件支持而能够在同一时间执行多个线程,提升性能. 1.2并发和并行[理解] 并 ...

认识死锁之生产者与消费者

认识死锁之生产者与消费者相关推荐

最新文章

热门文章