`
androidssh
  • 浏览: 115168 次
  • 性别: Icon_minigender_1
  • 来自: 深圳
社区版块
存档分类
最新评论

java多线程设计模式详解之二

 
阅读更多

 wait()/notify()

  通常,多线程之间需要协调工作。例如,浏览器的一个显示图片的线程displayThread想要执行显示图片的任务,必须等待下载线程downloadThread将该图片下载完毕。如果图片还没有下载完,displayThread可以暂停,当downloadThread完成了任务后,再通知displayThread“图片准备完毕,可以显示了”,这时,displayThread继续执行。

  以上逻辑简单的说就是:如果条件不满足,则等待。当条件满足时,等待该条件的线程将被唤醒。在Java中,这个机制的实现依赖于wait/notify。等待机制与锁机制是密切关联的。例如:

  synchronized(obj) {

  while(!condition) {

  obj.wait();

  }

  obj.doSomething();

  }

  当线程A获得了obj锁后,发现条件condition不满足,无法继续下一处理,于是线程A就wait()。

  在另一线程B中,如果B更改了某些条件,使得线程A的condition条件满足了,就可以唤醒线程A:

  synchronized(obj) {

  condition = true;

  obj.notify();

  }

  需要注意的概念是:

  # 调用obj的wait(), notify()方法前,必须获得obj锁,也就是必须写在synchronized(obj) {...} 代码段内。

  # 调用obj.wait()后,线程A就释放了obj的锁,否则线程B无法获得obj锁,也就无法在synchronized(obj) {...} 代码段内唤醒A。

  # 当obj.wait()方法返回后,线程A需要再次获得obj锁,才能继续执行。

  # 如果A1,A2,A3都在obj.wait(),则B调用obj.notify()只能唤醒A1,A2,A3中的一个(具体哪一个由JVM决定)。

  # obj.notifyAll()则能全部唤醒A1,A2,A3,但是要继续执行obj.wait()的下一条语句,必须获得obj锁,因此,A1,A2,A3只有一个有机会获得锁继续执行,例如A1,其余的需要等待A1释放obj锁之后才能继续执行。

  # 当B调用obj.notify/notifyAll的时候,B正持有obj锁,因此,A1,A2,A3虽被唤醒,但是仍无法获得obj锁。直到B退出synchronized块,释放obj锁后,A1,A2,A3中的一个才有机会获得锁继续执行。

  wait()/sleep()的区别

  前面讲了wait/notify机制,Thread还有一个sleep()静态方法,它也能使线程暂停一段时间。sleep与wait的不同点是:sleep并不释放锁,并且sleep的暂停和wait暂停是不一样的。obj.wait会使线程进入obj对象的等待集合中并等待唤醒。

  但是wait()和sleep()都可以通过interrupt()方法打断线程的暂停状态,从而使线程立刻抛出InterruptedException。

  如果线程A希望立即结束线程B,则可以对线程B对应的Thread实例调用interrupt方法。如果此刻线程B正在wait/sleep/join,则线程B会立刻抛出InterruptedException,在catch() {} 中直接return即可安全地结束线程。

  需要注意的是,InterruptedException是线程自己从内部抛出的,并不是interrupt()方法抛出的。对某一线程调用interrupt()时,如果该线程正在执行普通的代码,那么该线程根本就不会抛出InterruptedException。但是,一旦该线程进入到wait()/sleep()/join()后,就会立刻抛出InterruptedException。

  GuardedSuspention

  GuardedSuspention模式主要思想是:

  当条件不满足时,线程等待,直到条件满足时,等待该条件的线程被唤醒。

  我们设计一个客户端线程和一个服务器线程,客户端线程不断发送请求给服务器线程,服务器线程不断处理请求。当请求队列为空时,服务器线程就必须等待,直到客户端发送了请求。

  先定义一个请求队列:Queue

  package com.crackj2ee.thread;

  import java.util.*;

  public class Queue {

  private List queue = new LinkedList();

  public synchronized Request getRequest() {

  while(queue.size()==0) {

  try {

  this.wait();

  }

  catch(InterruptedException ie) {

  return null;

  }

  }

  return (Request)queue.remove(0);

  }

  public synchronized void putRequest(Request request) {

  queue.add(request);

  this.notifyAll();

  }

  }

  蓝色部分就是服务器线程的等待条件,而客户端线程在放入了一个request后,就使服务器线程等待条件满足,于是唤醒服务器线程。

  客户端线程:ClientThread

  package com.crackj2ee.thread;

  public class ClientThread extends Thread {

  private Queue queue;

  private String clientName;

  public ClientThread(Queue queue, String clientName) {

  this.queue = queue;

  this.clientName = clientName;

  }

  public String toString() {

  return "[ClientThread-" + clientName + "]";

  }

  public void run() {

  for(int i=0; i<100; i++) {

  Request request = new Request("" + (long)(Math.random()*10000));

  System.out.println(this + " send request: " + request);

  queue.putRequest(request);

  try {

  Thread.sleep((long)(Math.random() * 10000 + 1000));

  }

  catch(InterruptedException ie) {

  }

  }

  System.out.println(this + " shutdown.");

  }

  }

  服务器线程:ServerThread

  package com.crackj2ee.thread;

  public class ServerThread extends Thread {

  private boolean stop = false;

  private Queue queue;

  public ServerThread(Queue queue) {

  this.queue = queue;

  }

  public void shutdown() {

  stop = true;

  this.interrupt();

  try {

  this.join();

  }

  catch(InterruptedException ie) {}

  }

  public void run() {

  while(!stop) {

  Request request = queue.getRequest();

  System.out.println("[ServerThread] handle request: " + request);

  try {

  Thread.sleep(2000);

  }

  catch(InterruptedException ie) {}

  }

  System.out.println("[ServerThread] shutdown.");

  }

  }

  服务器线程在红色部分可能会阻塞,也就是说,Queue.getRequest是一个阻塞方法。这和java标准库的许多IO方法类似。

  最后,写一个Main来启动他们:

  package com.crackj2ee.thread;

  public class Main {

  public static void main(String[] args) {

  Queue queue = new Queue();

  ServerThread server = new ServerThread(queue);

  server.start();

  ClientThread[] clients = new ClientThread[5];

  for(int i=0; i<clients.length; i++) {

  clients[i] = new ClientThread(queue, ""+i);

  clients[i].start();

  }

  try {

  Thread.sleep(100000);

  }

  catch(InterruptedException ie) {}

  server.shutdown();

  }

  }

  我们启动了5个客户端线程和一个服务器线程,运行结果如下:

  [ClientThread-0] send request: Request-4984

  [ServerThread] handle request: Request-4984

  [ClientThread-1] send request: Request-2020

  [ClientThread-2] send request: Request-8980

  [ClientThread-3] send request: Request-5044

  [ClientThread-4] send request: Request-548

  [ClientThread-4] send request: Request-6832

  [ServerThread] handle request: Request-2020

  [ServerThread] handle request: Request-8980

  [ServerThread] handle request: Request-5044

  [ServerThread] handle request: Request-548

  [ClientThread-4] send request: Request-1681

  [ClientThread-0] send request: Request-7859

  [ClientThread-3] send request: Request-3926

  [ServerThread] handle request: Request-6832

  [ClientThread-2] send request: Request-9906

  ......

  可以观察到ServerThread处理来自不同客户端的请求。

  思考

  Q: 服务器线程的wait条件while(queue.size()==0)能否换成if(queue.size()==0)?

  A: 在这个例子中可以,因为服务器线程只有一个。但是,如果服务器线程有多个(例如Web应用程序有多个线程处理并发请求,这非常普遍),就会造成严重问题。

  Q: 能否用sleep(1000)代替wait()?

  A: 绝对不可以。sleep()不会释放锁,因此sleep期间别的线程根本没有办法调用getRequest()和putRequest(),导致所有相关线程都被阻塞。

  Q: (Request)queue.remove(0)可以放到synchronized() {}块外面吗?

  A: 不可以。因为while()是测试queue,remove()是使用queue,两者是一个原子操作,不能放在synchronized外面。

  总结

  多线程设计看似简单,实际上必须非常仔细地考虑各种锁定/同步的条件,稍不小心,就可能

分享到:
评论

相关推荐

    java多线程设计模式详解(PDF及源码)

    书中包含Java线程的介绍导读、12个重要的线程设计模式和全书总结以及丰富的附录内容。第一章相关线程设计模式的介绍,都举一反三使读者学习更有效。最后附上练习问题,让读者可以温故而知新,能快速地吸收书中的...

    java多线程设计模式详解(pdf版)

    java多线程设计模式,作者是:结城 浩,由 博硕文化 译。2005年4月,由中国铁道出版社出版。内附带部分源代码。

    java多线程设计模式详解(PDF及源码).zip

    Java多线程设计模式是...通过阅读“java多线程设计模式详解(PDF及源码)”的资料,我们可以深入了解这些知识点,并通过提供的源码加深理解,学习如何在实际项目中应用多线程设计模式,提高程序的并发性能和可维护性。

    java多线程设计模式详解

    Java多线程设计模式是Java编程中不可或缺的一部分,它涉及到如何在并发环境下高效、安全地组织代码...阅读提供的"java多线程设计模式详解.pdf"和"Java多线程设计模式源码"文件,将能更深入地理解这些模式的实际运用。

    java多线程设计模式详解+源码

    本资料包包含“java多线程设计模式详解”文档以及对应的源码,将帮助你深入理解并熟练运用Java多线程设计模式。 1. **线程的基本概念**:在Java中,线程是程序执行的最小单元,每个线程都有自己的程序计数器、...

    JAVA多线程设计模式详解

    本书“JAVA多线程设计模式详解”深入探讨了这一主题,旨在帮助开发者理解和掌握如何在Java环境中高效地使用多线程。 首先,基础内容介绍涵盖了线程的基本概念,包括进程与线程的区别,线程的创建方式,如通过实现...

    java多线程设计模式详解.rar

    本压缩包文件“java多线程设计模式详解.rar”显然提供了深入探讨这一主题的详细资料。 一、线程基础 在Java中,线程是程序中的执行流,每个线程都有自己的程序计数器、虚拟机栈、本地方法栈和堆。主线程启动后,...

    JAVA设计模式与JAVA多线程设计模式详解

    在Java编程领域,设计模式和多线程设计模式是开发者必备的技能。设计模式是一种在特定情境下解决软件设计问题的通用、可复用的解决方案,而多线程设计模式则是处理并发问题的关键。本文将深入探讨这两种重要的概念,...

    《Java多线程设计模式详解》(PDF及源码)

    这本书是很经典的! 如何充分利用系统资源,如何让你的软件跑得更...该书详细阐述了JAVA多线程的设计、开发并配有测试源代码,更值得注意是将多线程设计与设计模式结合起来,供我们设计大型服务器的多线程提供了帮助。

Global site tag (gtag.js) - Google Analytics