JAVA多线程机制之同步与互斥

简介:

一个多线程的程序,两个或者多个线程可能需要访问同一个数据资源。这时就必须考虑数据安全的问题,需要线程互斥或者同步。

线程的互斥

当多个线程需要访问同一资源时,要求在一个时间段内只能允许一个线程来操作共享资源,操作完毕后别的线程才能读取该资源,这叫线程的互斥。我们需要使用synchronized来给共享区域加锁,确保共享资源安全。
如果一个线程调用了某个对象的synchronized方法,它在这个方法运行完之前不会被别的线程打断,这就是线程的同步机制。一般将共享资源放在这个同步方法内部,这样就保证在一个线程对这个资源操作完之后别的线程才可以访问。
将共享资源放在同步方法或者同步代码块中可以保证一个线程对共享资源操作时不会被打断,凡是被synchronized修饰的资源,在运行的时候系统都要给它们分配一个管理程序,这需要消耗一部分资源。

使用示例

class NumCount
{
   public int count = 0;

   public synchronized void run()
   {
      for (int i = 1; i <= 100; i++)
      {
         Thread thread = Thread.currentThread();
         count = count + 1;
         System.out.printf("%s第%d次计数,count值为:%d\n", thread.getName(), i, count);
         try
         {
            // 睡眠5毫秒,给其它线程运行机会
            Thread.sleep(5);
         }
         catch (InterruptedException e)
         {
            e.printStackTrace();
         }
      }
   }
}

class SynchThread extends Thread
{
   private NumCount numCount = null;

   public SynchThread(String name, NumCount numCount)
   {
      super(name);
      this.numCount = numCount;
   }

   @Override
   public void run()
   {
      numCount.run();
   }
}

/**
 * 线程间互斥
 * 
 * @author jianggujin
 *
 */
public class SyncThreadDemo
{
   public static void main(String[] args)
   {
      NumCount numCount = new NumCount();
      SynchThread synchThread1 = new SynchThread("Thread-1", numCount);
      SynchThread synchThread2 = new SynchThread("Thread-2", numCount);
      SynchThread synchThread3 = new SynchThread("Thread-3", numCount);
      synchThread1.start();
      synchThread2.start();
      synchThread3.start();
      try
      {
         synchThread1.join();
         synchThread2.join();
         synchThread3.join();
      }
      catch (InterruptedException e)
      {
         e.printStackTrace();
      }
      System.out.println("计数器的值为:" + numCount.count);
   }
}

最后运行的结果计数器的值为300,大家可以尝试一下把synchronized 去掉,结果可能就会改变。

线程的同步

在某些情况下,线程需要交替执行。比如一个线程向一个存储单元执行存放数据,而另一个操作执行取值操作,线程间同步完成这个存取任务,需要将这些线程同步。要解决线程交替执行但是又要保证共享资源安全,这需要使用到JAVA3个方法:wait()、notify()和nodifyAll()、这3个方法是Object类的成员方法,所以在任何类中都可以使用这3个方法。

返回值 方法名 说明
public final void wait() 使当前线程睡眠,直到其它线程进入管程唤醒它
public final void notify() 唤醒此对象等待池中第一个调用wait()方法的线程
public final void nodifyAll() 唤醒此对象等待池中所有睡眠的线程

生产者-消费者问题是操作系统中的一个著名进程同步的问题。这个问题用线程思想表达出来就是说有一些生产线程产生数据放置在公共区,一些消费线程去提取消费数据。在这个问题中要保护公共资源的安全性,在生产者生产物资时消费线程必须等待不能打断生产线程,当生产到一定数量时,生产线程暂停让消费线程提取数据。我们来通过一个例子来演示这个过程:

import java.util.Vector;

/**
 * 工厂
 * 
 * @author jianggujin
 *
 */
class Factory
{
   private Vector<String> goods;
   // 标志货物上限
   private int goodFlag = 5;

   public Factory()
   {
      goods = new Vector<String>();
   }

   public synchronized void production()
   {
      if (goods.size() < goodFlag)
      {
         goods.addElement("货物" + (goods.size() + 1));
         System.out.printf("%s生产货物:货物%d,现有货物数量:%d\n", Thread.currentThread().getName(),
             (goods.size() + 1),
               goods.size());
         // 唤醒消费线程
         notifyAll();
      }
      else
      {
         System.out.println("货物已满可以取货");
         try
         {
            // 货物满等待消费
            wait();
         }
         catch (InterruptedException e)
         {
            System.out.println("生产事故...");
         }
      }
   }

   public synchronized void getProduction()
   {
      if (goods.size() < 1)
      {
         try
         {
            System.out.println("货物取完...");
            // 等待生产
            wait();
         }
         catch (InterruptedException e)
         {
            System.out.println("账户余额不足...");
         }
      }
      else
      {
         System.out.printf("%s取走货物:%s,还有货物数量:%d\n", Thread.currentThread().getName(),
             goods.elementAt(goods.size() - 1),
               goods.size());
         goods.remove(goods.size() - 1);
         // 唤醒生产线程
         notifyAll();
      }
   }
}

/**
 * 生产者
 * 
 * @author jianggujin
 *
 */
class ProductThread extends Thread
{
   private Factory factory = null;

   public ProductThread(String name, Factory factory)
   {
      super(name);
      this.factory = factory;
   }

   @Override
   public void run()
   {
      while (true)
      {
         factory.production();
         try
         {
            Thread.sleep(10);
         }
         catch (InterruptedException e)
         {
            System.out.println("生产事故...");
         }
      }
   }
}

/**
 * 消费者
 * 
 * @author jianggujin
 *
 */
class ConsumThread extends Thread
{
   private Factory factory = null;

   public ConsumThread(String name, Factory factory)
   {
      super(name);
      this.factory = factory;
   }

   @Override
   public void run()
   {
      while (true)
      {
         factory.getProduction();
         try
         {
            Thread.sleep(10);
         }
         catch (InterruptedException e)
         {
            System.out.println("账户余额不足...");
         }
      }
   }
}

/**
 * 生产者-消费者
 * 
 * @author jianggujin
 *
 */
public class ProducConsumDemo
{
   public static void main(String[] args)
   {
      Factory factory = new Factory();
      ProductThread productThread = new ProductThread("生产工厂", factory);
      ConsumThread consumThread = new ConsumThread("消费者", factory);
      productThread.start();
      consumThread.start();
   }
}
目录
相关文章
|
4月前
|
设计模式 人工智能 安全
AQS:Java 中悲观锁的底层实现机制
AQS(AbstractQueuedSynchronizer)是Java并发包中实现同步组件的基础工具,支持锁(如ReentrantLock、ReadWriteLock)和线程同步工具类(如CountDownLatch、Semaphore)等。Doug Lea设计AQS旨在抽象基础同步操作,简化同步组件构建。 使用AQS需实现`tryAcquire(int arg)`和`tryRelease(int arg)`方法以获取和释放资源,共享模式还需实现`tryAcquireShared(int arg)`和`tryReleaseShared(int arg)`。
234 32
AQS:Java 中悲观锁的底层实现机制
|
2月前
|
安全 算法 Java
Java 多线程:线程安全与同步控制的深度解析
本文介绍了 Java 多线程开发的关键技术,涵盖线程的创建与启动、线程安全问题及其解决方案,包括 synchronized 关键字、原子类和线程间通信机制。通过示例代码讲解了多线程编程中的常见问题与优化方法,帮助开发者提升程序性能与稳定性。
137 0
|
4月前
|
人工智能 Java 关系型数据库
Java——SPI机制详解
SPI(Service Provider Interface)是JDK内置的服务提供发现机制,主要用于框架扩展和组件替换。通过在`META-INF/services/`目录下定义接口实现类文件,Java程序可利用`ServiceLoader`动态加载服务实现。SPI核心思想是解耦,允许不同厂商为同一接口提供多种实现,如`java.sql.Driver`的MySQL与PostgreSQL实现。然而,SPI存在缺陷:需遍历所有实现并实例化,可能造成资源浪费;获取实现类方式不够灵活;多线程使用时存在安全问题。尽管如此,SPI仍是Java生态系统中实现插件化和模块化设计的重要工具。
155 0
|
2月前
|
人工智能 前端开发 安全
Java开发不可不知的秘密:类加载器实现机制
类加载器是Java中负责动态加载类到JVM的组件,理解其工作原理对开发复杂应用至关重要。本文详解类加载过程、双亲委派模型及常见类加载器,并介绍自定义类加载器的实现与应用场景。
185 4
|
3月前
|
Java 数据挖掘 调度
Java 多线程创建零基础入门新手指南:从零开始全面学习多线程创建方法
本文从零基础角度出发,深入浅出地讲解Java多线程的创建方式。内容涵盖继承`Thread`类、实现`Runnable`接口、使用`Callable`和`Future`接口以及线程池的创建与管理等核心知识点。通过代码示例与应用场景分析,帮助读者理解每种方式的特点及适用场景,理论结合实践,轻松掌握Java多线程编程 essentials。
233 5
|
3月前
|
监控 搜索推荐 Java
Java 多线程最新实操技术与应用场景全解析:从基础到进阶
本文深入探讨了Java多线程的现代并发编程技术,涵盖Java 8+新特性,如CompletableFuture异步处理、Stream并行流操作,以及Reactive编程中的Reactor框架。通过具体代码示例,讲解了异步任务组合、并行流优化及响应式编程的核心概念(Flux与Mono)。同时对比了同步、CompletableFuture和Reactor三种实现方式的性能,并总结了最佳实践,帮助开发者构建高效、扩展性强的应用。资源地址:[点击下载](https://pan.quark.cn/s/14fcf913bae6)。
252 3
|
4月前
|
算法 Java 调度
Java多线程基础
本文主要讲解多线程相关知识,分为两部分。第一部分涵盖多线程概念(并发与并行、进程与线程)、Java程序运行原理(JVM启动多线程特性)、实现多线程的两种方式(继承Thread类与实现Runnable接口)及其区别。第二部分涉及线程同步(同步锁的应用场景与代码示例)及线程间通信(wait()与notify()方法的使用)。通过多个Demo代码实例,深入浅出地解析多线程的核心知识点,帮助读者掌握其实现与应用技巧。
|
4月前
|
Java 区块链 网络架构
酷阿鲸森林农场:Java 区块链系统中的 P2P 区块同步与节点自动加入机制
本文介绍了基于 Java 的去中心化区块链电商系统设计与实现,重点探讨了 P2P 网络在酷阿鲸森林农场项目中的应用。通过节点自动发现、区块广播同步及链校验功能,系统实现了无需中心服务器的点对点网络架构。文章详细解析了核心代码逻辑,包括 P2P 服务端监听、客户端广播新区块及节点列表自动获取等环节,并提出了消息签名验证、WebSocket 替代 Socket 等优化方向。该系统不仅适用于农业电商,还可扩展至教育、物流等领域,构建可信数据链条。
|
4月前
|
Java
java 多线程异常处理
本文介绍了Java中ThreadGroup的异常处理机制,重点讲解UncaughtExceptionHandler的使用。通过示例代码展示了当线程的run()方法抛出未捕获异常时,JVM如何依次查找并调用线程的异常处理器、线程组的uncaughtException方法或默认异常处理器。文章还提供了具体代码和输出结果,帮助理解不同处理器的优先级与执行逻辑。
126 1
|
4月前
|
人工智能 JavaScript Java
Java反射机制及原理
本文介绍了Java反射机制的基本概念、使用方法及其原理。反射在实际项目中比代理更常用,掌握它可以提升编程能力并理解框架设计原理。文章详细讲解了获取Class对象的四种方式:对象.getClass()、类.class、Class.forName()和类加载器.loadClass(),并分析了Class.forName()与ClassLoader的区别。此外,还探讨了通过Class对象进行实例化、获取方法和字段等操作的具体实现。最后从JVM类加载机制角度解析了Class对象的本质及其与类和实例的关系,帮助读者深入理解Java反射的工作原理。
101 0