Java线程学习经典例子-读写者演示

简介: Java线程学习经典例子-读写者演示

Java线程学习经典例子-读写者演示


Java线程学习最经典的例子-读写者,主要用到Thread相关知识如下:


-         线程的start与run


-         线程的休眠(sleep)


-         数据对象加锁(synchronized)


-         数据对象的等待与释放(wait and notify)


程序实现:


-ObjectData数据类对象,通过synchronized关键字实现加锁,在线程读写者中使用。


-ConsumerThread消费者线程,读取数据对象中count值之后,通知生产者线程


-ProductThread生产者线程,对数据对象中count值操作,每次加1,然后通知消费者线程


类结构图如下:

代码实现

消费者-读线程

package com.gloomyfish.jse.thirdteen;
 
public class ConsumerThread extends Thread {
  private ObjectData data;
  public ConsumerThread(ObjectData data) {
    this.data = data;
  }
 
  @Override
  public void run() {
    while(true) {
      try {
        synchronized (data) {
          data.wait();
          data.read();
          data.notify();
        }
      } catch (InterruptedException e) {
        e.printStackTrace();
      }
    }
  }
 
}

写线程-生产者线程

package com.gloomyfish.jse.thirdteen;
 
public class ProductThread extends Thread {
  private ObjectData data;
 
  public ProductThread(ObjectData data) {
    this.data = data;
  }
 
  @Override
  public void run() {
    while (true) {
      try {
        synchronized (data) {
          data.write();
          Thread.sleep(3000);
          data.notify();
          data.wait();
        }
      } catch (InterruptedException e) {
        e.printStackTrace();
      }
    }
  }
 
}1.

数据对象类

package com.gloomyfish.jse.thirdteen;
 
public class ObjectData {
 
  private int count;
  
  public ObjectData() {
    count = 0;
  }
  
  public void read() {
    System.out.println("read count : " + count);
    System.out.println();
  }
  
  public void write() {
    count++;
    System.out.println("write count : " + count);
  }
}

测试代码:

  public static void main(String[] args) {
    ObjectData data = new ObjectData();
    ConsumerThread ct = new ConsumerThread(data);
    ProductThread pt = new ProductThread(data);
 
    ct.start();
    pt.start();
}

总结:

示例程序代码完成了线程之间如何通过wait与notify实现数据的读写

同步控制。演示了Java的同步关键字synchronized的用法与线程的用法。

相关文章
|
10天前
|
Java 调度
Java线程的六种状态
Java线程有六种状态: 初始(NEW)、运行(RUNNABLE)、阻塞(BLOCKED)、等待(WAITING)、超时等待(TIMED_WAITING)、终止(TERMINATED)。
27 1
|
21小时前
|
负载均衡 NoSQL Java
|
10天前
|
存储 安全 Java
Java面试题:请解释Java内存模型(JMM)是什么,它如何保证线程安全?
Java面试题:请解释Java内存模型(JMM)是什么,它如何保证线程安全?
52 13
|
2天前
|
安全 算法 Java
Java 中的并发控制:锁与线程安全
在 Java 的并发编程领域,理解并正确使用锁机制是实现线程安全的关键。本文深入探讨了 Java 中各种锁的概念、用途以及它们如何帮助开发者管理并发状态。从内置的同步关键字到显式的 Lock 接口,再到原子变量和并发集合,本文旨在为读者提供一个全面的锁和线程安全的知识框架。通过具体示例和最佳实践,我们展示了如何在多线程环境中保持数据的一致性和完整性,同时避免常见的并发问题,如死锁和竞态条件。无论你是 Java 并发编程的新手还是有经验的开发者,这篇文章都将帮助你更好地理解和应用 Java 的并发控制机制。
|
7天前
|
安全 Java 开发者
Java并发编程中的线程安全性与性能优化
在Java编程中,处理并发问题是至关重要的。本文探讨了Java中线程安全性的概念及其在性能优化中的重要性。通过深入分析多线程环境下的共享资源访问问题,结合常见的并发控制手段和性能优化技巧,帮助开发者更好地理解和应对Java程序中的并发挑战。 【7月更文挑战第14天】
|
7天前
|
监控 Java API
Java并发编程之线程池深度解析
【7月更文挑战第14天】在Java并发编程领域,线程池是提升性能、管理资源的关键工具。本文将深入探讨线程池的核心概念、内部工作原理以及如何有效使用线程池来处理并发任务,旨在为读者提供一套完整的线程池使用和优化策略。
|
10天前
|
缓存 安全 Java
Java中线程池如何管理?
【7月更文挑战第11天】Java中线程池如何管理?
19 2
|
10天前
|
安全 算法 Java
Java中线程安全怎么做?
【7月更文挑战第11天】Java中线程安全怎么做?
14 2
|
9天前
|
存储 安全 算法
深入理解Java并发编程:线程安全与性能优化
【5月更文挑战第72天】 在现代软件开发中,尤其是Java应用开发领域,并发编程是一个无法回避的重要话题。随着多核处理器的普及,合理利用并发机制对于提高软件性能、响应速度和资源利用率具有重要意义。本文旨在探讨Java并发编程的核心概念、线程安全的策略以及性能优化技巧,帮助开发者构建高效且可靠的并发应用。通过实例分析和理论阐述,我们将揭示在高并发环境下如何平衡线程安全与系统性能之间的关系,并提出一系列最佳实践方法。
|
9天前
|
Java 调度
java中线程的6种状态
java中线程的6种状态