学院首页>网络编程>JSP>Java 程序中的多线程

Java 程序中的多线程

作者: 来源: 添加时间:2006-5-24 13:02:03

  Runnable 接口
  此接口只有一个函数,run(),此函数必须由实现了此接口的类实现。但是,就运行这个类而论,其语义与前一个示例稍有不同。我们可以用 runnable 接口改写前一个示例。(不同的部分用黑体表示。)

  创建两个新线程而不强加类层次

  import java.util.*;

  class TimePrinter implements Runnable {
   int pauseTime;
   String name;
   public TimePrinter(int x, String n) {
   pauseTime = x;
   name = n;
   }

   public void run() {
   while(true) {
   try {
   System.out.println(name + ":" + new
   Date(System.currentTimeMillis()));
   Thread.sleep(pauseTime);
   } catch(Exception e) {
   System.out.println(e);
   }
   }
   }

   static public void main(String args[]) {
   Thread t1 = new Thread(new TimePrinter(1000, "Fast Guy"));
   t1.start();
   Thread t2 = new Thread(new TimePrinter(3000, "Slow Guy"));
   t2.start();
  
   }
  }

  请注意,当使用 runnable 接口时,您不能直接创建所需类的对象并运行它;必须从 Thread 类的一个实例内部运行它。许多程序员更喜欢 runnable 接口,因为从 Thread 类继承会强加类层次。

  synchronized 关键字
  到目前为止,我们看到的示例都只是以非常简单的方式来利用线程。只有最小的数据流,而且不会出现两个线程访问同一个对象的情况。但是,在大多数有用的程序中,线程之间通常有信息流。试考虑一个金融应用程序,它有一个 Account 对象,如下例中所示:

  一个银行中的多项活动

  public class Account {
   String holderName;
   float amount;
   public Account(String name, float amt) {
   holderName = name;
   amount = amt;
   }

   public void deposit(float amt) {
   amount += amt;
   }

   public void withdraw(float amt) {
   amount -= amt;
   }

   public float checkBalance() {
   return amount;
   }
  }

  在此代码样例中潜伏着一个错误。如果此类用于单线程应用程序,不会有任何问题。但是,在多线程应用程序的情况中,不同的线程就有可能同时访问同一个 Account 对象,比如说一个联合帐户的所有者在不同的 ATM 上同时进行访问。在这种情况下,存入和支出就可能以这样的方式发生:一个事务被另一个事务覆盖。这种情况将是灾难性的。但是,Java 编程语言提供了一种简单的机制来防止发生这种覆盖。每个对象在运行时都有一个关联的锁。这个锁可通过为方法添加关键字 synchronized 来获得。这样,修订过的 Account 对象(如下所示)将不会遭受像数据损坏这样的错误:

  对一个银行中的多项活动进行同步处理

  public class Account {
   String holderName;
   float amount;
   public Account(String name, float amt) {
   holderName = name;
   amount = amt;
   }

   public synchronized void deposit(float amt) {
   amount += amt;
   }

   public synchronized void withdraw(float amt) {
   amount -= amt;
   }

   public float checkBalance() {
   return amount;
   }
  }

  deposit() 和 withdraw() 函数都需要这个锁来进行操作,所以当一个函数运行时,另一个函数就被阻塞。请注意, checkBalance() 未作更改,它严格是一个读函数。因为 checkBalance() 未作同步处理,所以任何其他方法都不会阻塞它,它也不会阻塞任何其他方法,不管那些方法是否进行了同步处理。

  Java 编程语言中的高级多线程支持

  线程组
  线程是被个别创建的,但可以将它们归类到线程组中,以便于调试和监视。只能在创建线程的同时将它与一个线程组相关联。在使用大量线程的程序中,使用线程组组织线程可能很有帮助。可以将它们看作是计算机上的目录和文件结构。

  线程间发信
  当线程在继续执行前需要等待一个条件时,仅有 synchronized 关键字是不够的。虽然 synchronized 关键字阻止并发更新一个对象,但它没有实现线程间发信。Object 类为此提供了三个函数:wait()、notify() 和 notifyAll()。以全球气候预测程序为例。这些程序通过将地球分为许多单元,在每个循环中,每个单元的计算都是隔离进行的,直到这些值趋于稳定,然后相邻单元之间就会交换一些数据。所以,从本质上讲,在每个循环中各个线程都必须等待所有线程完成各自的任务以后才能进入下一个循环。这个模型称为 屏蔽同步,下例说明了这个模型:

  屏蔽同步

  public class BSync {
   int totalThreads;
   int currentThreads;

   public BSync(int x) {
   totalThreads = x;
   currentThreads = 0;
   }

   public synchronized void waitForAll() {
   currentThreads++;
   if(currentThreads < totalThreads) {
   try {
   wait();
   } catch (Exception e) {}
   }
   else {
   currentThreads = 0;
   notifyAll();
   }
   }
  }

  当对一个线程调用 wait() 时,该线程就被有效阻塞,只到另一个线程对同一个对象调用 notify() 或 notifyAll() 为止。因此,在前一个示例中,不同的线程在完成它们的工作以后将调用 waitForAll() 函数,最后一个线程将触发 notifyAll() 函数,该函数将释放所有的线程。第三个函数 notify() 只通知一个正在等待的线程,当对每次只能由一个线程使用的资源进行访问限制时,这个函数很有用。但是,不可能预知哪个线程会获得这个通知,因为这取决于 Java 虚拟机 (JVM) 调度算法。

  将 CPU 让给另一个线程
  当线程放弃某个稀有的资源(如数据库连接或网络端口)时,它可能调用 yield() 函数临时降低自己的优先级,以便某个其他线程能够运行。

  守护线程
  有两类线程:用户线程和守护线程。用户线程是那些完成有用工作的线程。 守护线程是那些仅提供辅助功能的线程。Thread 类提供了 setDaemon() 函数。Java 程序将运行到所有用户线程终止,然后它将破坏所有的守护线程。在 Java 虚拟机 (JVM) 中,即使在 main 结束以后,如果另一个用户线程仍在运行,则程序仍然可以继续运行。
第 2 页,共 2 页 [1] [2]
站内搜索