现在在学java基础,在看一些马士兵老师的视频,确实通俗易懂。
最近看到线程这一章时,发现运行 消费者和生产者 代码部分时,总会出现先消费 后生产。
源代码如下:
public class ProducerConsumer { public static void main(String[] args) { SyncStack ss = new SyncStack(); Producer p = new Producer(ss); Consumer c = new Consumer(ss); new Thread(p).start(); new Thread(c).start(); } } class WoTou { int id; WoTou(int id) { this.id = id; } public String toString() { return "WoTou : " + id; } } class SyncStack { int index = 0; WoTou[] arrWT = new WoTou[6]; public synchronized void push(WoTou wt) { while(index == arrWT.length) { try { this.wait(); } catch (InterruptedException e) { e.printStackTrace(); } } this.notifyAll(); arrWT[index] = wt; index ++; } public synchronized WoTou pop() { while(index == 0) { try { this.wait(); } catch (InterruptedException e) { e.printStackTrace(); } } this.notifyAll(); index--; return arrWT[index]; } } class Producer implements Runnable { SyncStack ss = null; Producer(SyncStack ss) { this.ss = ss; } public void run() { for(int i=0; i<20; i++) { WoTou wt = new WoTou(i); ss.push(wt); System.out.println("生产了:" + wt); try { Thread.sleep((int)(Math.random() * 200)); } catch (InterruptedException e) { e.printStackTrace(); } } } } class Consumer implements Runnable { SyncStack ss = null; Consumer(SyncStack ss) { this.ss = ss; } public void run() { for(int i=0; i<20; i++) { WoTou wt = ss.pop(); System.out.println("消费了: " + wt); try { Thread.sleep((int)(Math.random() * 1000)); } catch (InterruptedException e) { e.printStackTrace(); } } } }
运行结果:
消费了: WoTou : 0
生产了:WoTou : 0
生产了:WoTou : 1
生产了:WoTou : 2
生产了:WoTou : 3
生产了:WoTou : 4
消费了: WoTou : 4
生产了:WoTou : 5
生产了:WoTou : 6
生产了:WoTou : 7
消费了: WoTou : 7
生产了:WoTou : 8
消费了: WoTou : 8
生产了:WoTou : 9
消费了: WoTou : 9
生产了:WoTou : 10
消费了: WoTou : 10
生产了:WoTou : 11
消费了: WoTou : 11
生产了:WoTou : 12
生产了:WoTou : 13
消费了: WoTou : 12
生产了:WoTou : 14
消费了: WoTou : 13
消费了: WoTou : 14
生产了:WoTou : 15
消费了: WoTou : 15
生产了:WoTou : 16
消费了: WoTou : 16
生产了:WoTou : 17
消费了: WoTou : 17
生产了:WoTou : 18
消费了: WoTou : 18
生产了:WoTou : 19
消费了: WoTou : 19
消费了: WoTou : 6
消费了: WoTou : 5
消费了: WoTou : 3
消费了: WoTou : 2
消费了: WoTou : 1
应该是线程出现问题,在push()方法结束后,要打印生产了第几个窝头时,另一线程执行了起来,导致消费在生产之前。
修改代码:把打印部分都放进push()和pop()方法内,同时pop()方法返回类型为void。
代码如下:
public class ProducerConsumer { public static void main(String[] args) { SyncStack ss = new SyncStack(); Producer p = new Producer(ss); Consumer c = new Consumer(ss); new Thread(p).start(); new Thread(c).start(); } } class WoTou { int id; WoTou(int id) { this.id = id; } public String toString() { return "WoTou : " + id; } } class SyncStack { int index = 0; WoTou[] arrWT = new WoTou[6]; public synchronized void push(WoTou wt) { while(index == arrWT.length) { try { this.wait(); } catch (InterruptedException e) { e.printStackTrace(); } } this.notifyAll(); arrWT[index] = wt; index ++; System.out.println("生产了:" + wt); } public synchronized void pop() { while(index == 0) { try { this.wait(); } catch (InterruptedException e) { e.printStackTrace(); } } this.notifyAll(); index--; System.out.println("消费了: " + arrWT[index]); } } class Producer implements Runnable { SyncStack ss = null; Producer(SyncStack ss) { this.ss = ss; } public void run() { for(int i=0; i<20; i++) { WoTou wt = new WoTou(i); ss.push(wt); try { Thread.sleep((int)(Math.random() * 200)); } catch (InterruptedException e) { e.printStackTrace(); } } } } class Consumer implements Runnable { SyncStack ss = null; Consumer(SyncStack ss) { this.ss = ss; } public void run() { for(int i=0; i<20; i++) { ss.pop(); try { Thread.sleep((int)(Math.random() * 1000)); } catch (InterruptedException e) { e.printStackTrace(); } } } }
相关推荐
10. **线程间的通信**:Java的BlockingQueue接口和相关的类(如ArrayBlockingQueue、LinkedBlockingQueue)提供了一种线程间通信的方式,允许线程在生产数据和消费数据之间进行协作。 马士兵的多线程训练营资料1和...
5. **线程通信**:wait()、notify()、notifyAll()方法的使用,以及在生产者消费者模型、哲学家就餐问题等经典示例中的应用。 6. **线程池**:ExecutorService、ThreadPoolExecutor和Future接口的理解,线程池的配置...
9. **线程通信**:理解wait()、notify()和notifyAll()方法,以及在生产者消费者模型中的应用。 10. **原子操作与CAS**:学习Atomic类和CompareAndSwap(CAS)算法,以及它们在无锁编程中的应用。 通过学习这份预习...
总的来说,这个资源包为Java初学者提供了一个全面的学习路径,通过马士兵的专业讲解和源码实例,能够帮助学习者扎实地掌握J2SE,为后续的Java EE和Android开发打下坚实的基础。同时,对于有一定经验的开发者,这些...
"J2SE上半部分_马士兵"可能是指一个由知名IT教育专家马士兵制作的Java基础教学课程或教材,旨在帮助初学者掌握Java编程的基础知识。 在这个压缩包中,可能包含了马士兵讲解J2SE基础知识的各种资源,如视频教程、...
### 马士兵JVM调优笔记知识点梳理 #### 一、Java内存结构 Java程序运行时,其内存被划分为几个不同的区域,包括堆内存(Heap)、方法区(Method Area)、栈(Stack)、程序计数器(Program Counter Register)以及...
【马士兵 J2SE代码+PPT教材】是针对Java初学者和爱好者提供的一套学习资源,由知名IT教育专家马士兵编著。这套教材涵盖了Java Standard Edition (J2SE) 的核心概念和技术,旨在帮助读者掌握Java编程的基础知识和实践...
马士兵老师是知名的Java教育专家,他的Spring框架学习笔记深入浅出,对于初学者和进阶者来说都是一份宝贵的资源。这份笔记涵盖了Spring的核心概念、配置、AOP(面向切面编程)、DI(依赖注入)等关键知识点。 1. **...
总的来说,马士兵老师的HashMap学习笔记不仅涵盖了HashMap的基础知识,还深入探讨了其在不同JDK版本中的实现细节,特别是并发环境下的问题和解决方案。理解这些内容对于提升Java编程技能和优化代码性能具有重要价值...
jvm java虚拟机 调优 马士兵 笔记 让你对java虚拟机调优有初步的认识
本课程基于马士兵老师的java高并发编程公开课,深入探讨了多线程在实际应用中的重要性及其使用技巧。通过对源码的分析,我们可以更直观地理解并发控制、线程安全以及性能优化等核心概念。 一、多线程基础 多线程是...
马士兵oracle笔记,浅显易懂。
总结,马士兵百万级并发IM即时消息系统充分利用了Go语言和Gin框架的优势,构建了一个能够处理大规模并发的即时通讯平台。在设计上,系统注重性能优化、安全性、扩展性以及可维护性,确保在高负载下也能提供稳定的...
马士兵的教程中,他将带领我们深入理解如何利用Java的Servlet、JSP(JavaServer Pages)以及MVC(Model-View-Controller)设计模式来构建后端逻辑和前端界面。 1. **Servlet与JSP**:Servlet是Java EE中处理HTTP...
马士兵JAVA笔记(全) 本资源是马士兵的JAVA笔记,涵盖了JAVA语言的基础知识,包括标识符、常量、变量、数据类型、运算符、控制流语句等。 标识符是JAVA中的一种符号,用于命名变量、方法、类等。标识符由字母、...
Struts2是一个流行的Java web框架,...以上就是"马士兵Struts2笔记2013"中涉及的主要知识点,这些内容涵盖了Struts2的基础配置、数据处理、验证、调试以及与视图层的交互等方面,对于理解和掌握Struts2框架非常有帮助。
马士兵是一位知名的IT教育专家,他的课程深入浅出,适合初学者和有一定基础的学习者。这个“马士兵 html css js源码”压缩包很可能包含了他在教学过程中用到的各种实例和特效代码,是学习和实践这些技术的宝贵资源。...
"马士兵Shopping项目"是其精心设计的一个教学实例,旨在帮助学员理解并掌握电商网站的开发流程和技术要点。这个项目源代码的详细分析,将为我们揭示一个完整的购物系统背后的架构设计和实现细节。 1. **项目结构...
在马士兵的Python基础版2020教程P98-P134部分,我们学习了Python编程中的几个核心概念,包括数据结构、异常处理以及面向对象编程的基础。 1. **列表遍历与嵌套**: 示例代码展示了如何遍历包含字典的列表来查找...
"02-4(马士兵)-多线程并发"可能是一个教学资源,由马士兵老师讲解,涵盖了多线程并发的相关知识。在Java中,Java Util Concurrency (JUC) 工具包提供了强大的并发编程支持,这可能是课程内容的重点。 并发是指系统...