• 2009-7-9 18:36
• 回复

• zhutou8033
• 0位粉丝

2楼

//Consumer.java 　　import java.util.*; 　　class Consumer extends Thread 　　{ 　　 int nTime; 　　 String strConsumer; 　　 public Consumer(int nTime, String strConsumer) 　　 { 　　 this.nTime = nTime; 　　 this.strConsumer = strConsumer; 　　 } 　　 public void run() 　　 { 　　while(true) 　　{ 　　 try 　　{ 　　 System.out.println("Consumer name:"+strConsumer+"\n"); 　　 Thread.sleep(nTime); 　　 } 　　catch(Exception e) 　　{ 　　 e.printStackTrace(); 　　 } 　　} 　　 } 　　static public void main(String args[]) 　　{ 　　 Consumer aConsumer = new Consumer (1000, "aConsumer"); 　　 aConsumer.start(); 　　 Consumer bConsumer = new Consumer (2000, "bConsumer"); 　　 bConsumer.start(); 　　 Consumer cConsumer = new Consumer (3000, "cConsumer "); 　　 cConsumer.start(); 　　} 　　}  
  
　　 　　 　　 　　 　　从上面的程序代码可以看出：多线程执行地下Consumer继承Java语言中的线程类Thread并且在main方法中创建了三个Consumer对象的实例。当调用对象实例的start方法时，自动调用Consumer类中定义的run方法启动对象线程运行。线程运行的结果是每间隔nTime时间打印出对象实例中的字符串成员变量strConsumer的内容。 　　 　　可以总结出继承Thread类的多线程程序设计方法是使应用程序类继承Thread类并且在该类的run方法中实现并发性处理过程。 　　 　　实现Runnable接口的多线程程序设计方法 　　 　　Java语言中提供的另外一种实现多线程应用程序的方法是多线程对象实现Runnable接口并且在该类中定义用于启动线程的run方法。这种定义方式的好处在于多线程应用对象可以继承其它对象而不是必须继承Thread类，从而能够增加类定义的逻辑性。 　　 　　实现Runnable接口的多线程应用程序框架代码如下所示： 　　 　　//Consumer.java 　　import java.util.*; 　　class Consumer implements Runnable 　　{ 　　 … … 　　public Consumer(int nTime, String strConsumer){… …} 　　public void run(){… …} 　　static public void main(String args[]) 　　{ 　　Thread aConsumer = new Thread(new Consumer(1000, "aConsumer")); 　　aConsumer.start(); 　　//其它对象实例的运行线程 　　 //… … 　　 } 　　} 　　 　　从上述代码可以看出：该类实现了Runnable接口并且在该类中定义了run方法。这种多线程应用程序的实现方式与继承Thread类的多线程应用程序的重要区别在于启动多线程对象的方法设计方法不同。在上述代码中，通过创建Thread对象实例并且将应用对象作为创建Thread类实例的参数。 四、线程间的同步 　　 　　Java应用程序的多个线程共享同一进程的数据资源，多个用户线程在并发运行过程中可能同时访问具有敏感性的内容。在Java中定义了线程同步的概念，实现对共享资源的一致性维护。下面以笔者最近开发的移动通信计费系统中线程间同步控制方法，说明Java语言中多线程同步方式的实现过程。 　　 　　在没有多线程同步控制策略条件下的客户账户类定义框架代码如下所示： 　　 　　public class RegisterAccount 　　{ 　　float fBalance; 　　//客户缴费方法 　　public void deposit(float fFees){ fBalance += fFees; } 　　//通话计费方法 　　public void withdraw(float fFees){ fBalance -= fFees; } 　　… … 　　} 　　 　　 　　 　　 　　读者也许会认为：上述程序代码完全能够满足计费系统实际的需要。确实，在单线程环境下该程序确实是可靠的。但是，多进程并发运行的情况是怎样的呢？假设发生这种情况：客户在客户服务中心进行缴费的同时正在利用移动通信设备仅此通话，客户通话结束时计费系统启动计费进程，而同时服务中心的工作人员也提交缴费进程运行。

• 2009-7-9 18:36
• 回复

• zhutou8033
• 0位粉丝

3楼

读者可以看到如果发生这种情况，对客户账户的处理是不严肃的。 　　 　　如何解决这种问题呢？很简单，在RegisterAccount类方法定义中加上用于标识同步方法的关键字synchronized。这样，在同步方法执行过程中该方法涉及的共享资源（在上述代码中为fBalance成员变量）将被加上共享锁，以确保在方法运行期间只有该方法能够对共享资源进行访问，直到该方法的线程运行结束打开共享锁，其它线程才能够访问这些共享资源。在共享锁没有打开的时候其它访问共享资源的线程处于阻塞状态。 　　 　　进行线程同步策略控制后的RegisterAccount类定义如下面代码所示： 　　 　　public class RegisterAccount 　　{ 　　float fBalance; 　　public synchronized void deposit(float fFees){ fBalance += fFees; } 　　public synchronized void withdraw(float fFees){ fBalance -= fFees; } 　　… … 　　} 　　 　　从经过线程同步机制定义后的代码形式可以看出：在对共享资源进行访问的方法访问属性关键字（public）后附加同步定义关键字synchronized，使得同步方法在对共享资源访问的时候，为这些敏感资源附加共享锁来控制方法执行期间的资源独占性，实现了应用系统数据资源的一致性管理和维护。 五、 Java线程的管理 　　 　　 　　线程的状态控制 　　 　　在这里需要明确的是：无论采用继承Thread类还是实现Runnable接口来实现应用程序的多线程能力，都需要在该类中定义用于完成实际功能的run方法，这个run方法称为线程体（Thread Body）。按照线程体在计算机系统内存中的状态不同，可以将线程分为创建、就绪、运行、睡眠、挂起和死亡等类型。这些线程状态类型下线程的特征为： 　　 　　创建状态：当利用new关键字创建线程对象实例后，它仅仅作为一个对象实例存在，JVM没有为其分配CPU时间片等线程运行资源； 　　 　　就绪状态：在处于创建状态的线程中调用start方法将线程的状态转换为就绪状态。这时，线程已经得到除CPU时间之外的其它系统资源，只等JVM的线程调度器按照线程的优先级对该线程进行调度，从而使该线程拥有能够获得CPU时间片的机会。 　　 　　睡眠状态：在线程运行过程中可以调用sleep方法并在方法参数中指定线程的睡眠时间将线程状态转换为睡眠状态。这时，该线程在不释放占用资源的情况下停止运行指定的睡眠时间。时间到达后，线程重新由JVM线程调度器进行调度和管理。 　　 　　挂起状态：可以通过调用suspend方法将线程的状态转换为挂起状态。这时，线程将释放占用的所有资源，由JVM调度转入临时存储空间，直至应用程序调用resume方法恢复线程运行。 　　 　　死亡状态：当线程体运行结束或者调用线程对象的stop方法后线程将终止运行，由JVM收回线程占用的资源。 　　 　　在Java线程类中分别定义了相应的方法，用于在应用程序中对线程状态进行控制和管理。 　　 　　线程的调度 　　 　　线程调用的意义在于JVM应对运行的多个线程进行系统级的协调，以避免多个线程争用有限资源而导致应用系统死机或者崩溃。 　　 　　为了线程对于操作系统和用户的重要性区分开，Java定义了线程的优先级策略。Java将线程的优先级分为10个等级，分别用1-10之间的数字表示。数字越大表明线程的级别越高。相应地，在Thread类中定义了表示线程最低、最高和普通优先级的成员变量MIN_PRIORITY、MAX_PRIORITY和NORMAL_PRIORITY，代表的优先级等级分别为1、10和5。当一个线程对象被创建时，其默认的线程优先级是5。 　　 　　为了控制线程的运行策略，Java定义了线程调度器来监控系统中处于就绪状态的所有线程。线程调度器按照线程的优先级决定那个线程投入处理器运行。在多个线程处于就绪状态的条件下，具有高优先级的线程会在低优先级线程之前得到执行。线程调度器同样采用"抢占式"策略来调度线程执行，即当前线程执行过程中有较高优先级的线程进入就绪状态，则高优先级的线程立即被调度执行。具有相同优先级的所有线程采用轮转的方式来共同分配CPU时间片。 　　 　　在应用程序中设置线程优先级的方法很简单，在创建线程对象之后可以调用线程对象的setPriority方法改变该线程的运行优先级，同样可以调用getPriority方法获取当前线程的优先级。 　　 　　在Java中比较特殊的线程是被称为守护（Daemon）线程的低级别线程。这个线程具有最低的优先级，用于为系统中的其它对象和线程提供服务。将一个用户线程设置为守护线程的方式是在线程对象创建之前调用线程对象的setDaemon方法。典型的守护线程例子是JVM中的系统资源自动回收线程，它始终在低级别的状态中运行，用于实时监控和管理系统中的可回收资源。 　　 　　线程分组管理 　　 　　Java定义了在多线程运行系统中的线程组（ThreadGroup）对象，用于实现按照特定功能对线程进行集中式分组管理。