`
158067568
  • 浏览: 327141 次
  • 性别: Icon_minigender_1
  • 来自: 北京
社区版块
存档分类
最新评论

java 多线程 高手进阶 一

    博客分类:
  • j2se
阅读更多

多线程菜鸟进阶 一

QQ158067568

作者:Legend

本文将进入多线程的学习中。在开始之前,需要明白线程的概念。

线程不是进程

作为有一定开发经验的程序员来说,在java中实现多线程是一件很容易的事情,你只需要将你的类继承Thread类或者实现Runnable接口就可以。其实线程完全可以理解为一个任务。可以同时运行多个任务的程序,就成为多线程程序。

然而线程并非进程。进程包括线程,每一个进程都拥有一套自己的变量,而线程间则共享这套变量。从而带来了很多风险,比如最典型的脏数据。这些以后会讨论。

线程状态

java中,线程被定义成有6中状态:

NEW

至今尚未启动的线程处于这种状态。 即刚刚new出来的Thread,但是还未调用start()方法。

RUNNABLE

正在 Java 虚拟机中执行的线程处于这种状态。 该状态是调用了start()方法后的状态,出于该状态的线程不一定是正在运行的,他有线程调度器来决定是否运行。

BLOCKED

受阻塞并等待某个监视器锁的线程处于这种状态。 阻塞与等待不同,阻塞通常是得不到所需要的资源而被迫停下来等待。

WAITING

无限期地等待另一个线程来执行某一特定操作的线程处于这种状态。

TIMED_WAITING

等待另一个线程来执行取决于指定等待时间的操作的线程处于这种状态。

TERMINATED

已退出的线程处于这种状态。有两种情况会让线程退出,其一是run方法中的任务执行完成,其二是线程执行时出现异常。

java的线程状态只有如上6中,他们以enum形式被定义在Thread.State中。这里要说一下等待状态,有很多方式能够让线程进入等待状态,比如调用join()方法。

join()

对于这个方法,还是要特别的强调一下。在api中的解释如下:Blocks the current Thread (Thread.currentThread()) until the receiver finishes its execution and dies.翻译过来就是:阻塞当前线程,然后让接受者完成任务之后,当前线程才开始继续执行任务。

但是如果接受者在被调用了join方法后,有被调用了interrupt()方法,则会抛出java.lang.InterruptedException异常。可以参考代码ThreadDemo01

 

package cn.edu.heut.zcl;

 

public class ThreadDemo01 {

 

         public static void main(String[] args) {

                   TA ta = new TA();

                   ta.start();

                   try {

                            ta.join();

                   } catch (InterruptedException e) {

                            e.printStackTrace();

                   }

                   int i = 0;

                   while ((i++) < 10) {

                            System.out.println("-------");

                            try {

                                     Thread.sleep(100);

                            } catch (InterruptedException e) {

                                     e.printStackTrace();

                            }

                   }

         }

}

class TA extends Thread {

 

         @Override

         public void run() {

                   super.run();

                   int i = 0;

                   while ((i++) < 40) {

                            System.out.println("---->A");

                            if (i == 10) {

                                     Thread.currentThread().interrupt();

                            }


                            try {

                                     Thread.sleep(100);

                            } catch (InterruptedException e) {

                                     // TODO Auto-generated catch block

                                     e.printStackTrace();

                            }

                   }

         }

}


 

 

 

 

记住:join()方法是将当前线程阻塞

interrupt()与中断线程

开发时常常需要用到中断线程,在早期的java版本中,有stop()等方法用来控制线程生死,当时这些方法现在已经废弃,具体愿意以后会谈,同时亦可以参考sun的一片文章《Why Are Thread.stop, Thread.suspend, Thread.resume and Runtime.runFinalizersOnExit Deprecated?》网址如下:

http://download.oracle.com/javase/1.5.0/docs/guide/misc/threadPrimitiveDeprecation.html

当然,jdk还是为我们提供了强化终止线程的方法。然而,interrupt方法只是可以用来请求终止线程。当对一个线程调用interrupt方法之后,线程的中断状态将被置位。每一个线程都具有一个中断状态,他是一个boolean标志。在实现自己的线程时,应该实时检查该标志,以判断线程是否被中断。

可以通过Thread.currentThread()方法得到当前线程,然后通过is isInterrupted()方法,来查看中断状态。通常如下实现:

while (!Thread.currentThread().isInterrupted() && 。。。) {}

如果你已经运行了ThreadDemo01代码,那么你会发现,在TA类中如下代码处:

if (i == 10) {

                                     Thread.currentThread().interrupt();

                            }

 

 

 

 

将会抛出异常java.lang.InterruptedException。这个是由于在TA线程中调用了interrupt方法后,中断状态已经置为,如果此时再调用sleep等阻塞方法后,该线程不会休眠,想法,他将抛出中断异常并且将中断状态清楚。所以如下代码是不会让线程TB停止。CopyOfThreadDemo02

 

package cn.edu.heut.zcl;

 

public class CopyOfThreadDemo02 {

 

         public static void main(String[] args) {

                   TB ta = new TB();

                   ta.start();

                   int i = 0;

                   while ((i++) < 10) {

                            System.out.println("-------");

                            try {

                                     Thread.sleep(100);

                            } catch (InterruptedException e) {

                                     e.printStackTrace();

                            }

                   }

         }

}

 

class TB extends Thread {

 

         @Override

         public void run() {

                   super.run();

                   int i = 0;

                   while (!Thread.currentThread().isInterrupted() && (i++) < 40) {

                            System.out.println("---->A");

                            if(i == 4) Thread.currentThread().interrupt();//在sleep之前调用,将不能终止线程

                            try {

                                     Thread.sleep(100);

                            } catch (InterruptedException e) {

                                     // TODO Auto-generated catch block

                                     e.printStackTrace();

                            }

                            //if(i == 4) Thread.currentThread().interrupt();//在sleep之后调用,将能终止线程

                   }

         }

}

 

 

 

 

你可以自己试一试,运行如上代码,不能中断TB线程。但是如果在sleep之后调用interrupt,则会中断线程。

interrupted()isInterrupted()

这两个方法看上去很像,作用也相似可以通过下表来比较两种异同。

 

是否是static

返回值

不同

interrupted

当前的中断状态

调用后改变中断状态

isInterrupted

不改变

 

线程属性----线程优先级

 

谈优先级可能并不陌生,在java中,每一个线程都有一个优先级。默认情况下,一个线程的优先级直接继承自他的父类。sunjava的优先级分成10级,1表示最小优先级,10表示最高优先级。同时jdk中还定义了3个常量MIN_PRIORITY(1)MAX_PRIORITY(10)NORM_PRIORITY(5)

线程的优先级是依赖与平台的,windows中有7个优先级。而在Linux中,java虚拟机将线程的优先级忽略,即所有线程的优先级都一样。所以在编写程序是,尽量不要依赖于优先级。

setPriority()方法,顾名思义就是设置优先级的。

yield()

yield的中文意思是:屈服。其实理解成让步更加准确。调用该方法,将导致当前执行线程出于让步状态。如果此时有其他线程一起来抢夺cpu资源,那么只要这个抢夺的线程的优先级不低于调用线程。则抢夺线程将会被调用。

线程属性----守护线程

守护线程的用途就是为其他线程提供服务。当被服务者死亡后,其也就没有存在的价值,也就跟着去死了。设置守护线程很简单:

setDaemontrue

只需一步,轻松搞定。在使用守护线程时需要记住,永远不要去访问固有资源,如文件、数据库等。以为你不知道什么时候守护线程会结束。

可以参考DeamonDemo

 

package cn.edu.heut.zcl;

/**

 * 演示守护线程

 * @author Legend

 *

 */

public class DeamonDemo {

         

         public static void main(String[] args){

                   DemonRunnable dr = new DemonRunnable();

                   dr.setDaemon(true);//设置为守护线程

                   dr.start();

                   int i = 0 ;

                   while((i++)<10){

                            try {

                                     Thread.sleep(500);

                                     System.out.println(i);

                            } catch (InterruptedException e) {

                                     e.printStackTrace();

                            }

                   }

         }

         

         private static class DemonRunnable extends Thread{

                   @Override

                   public void run() {

                            super.run();

                            while(true){

                                     System.out.println("------");

                                     try {

                                               Thread.sleep(100);

                                     } catch (InterruptedException e) {

                                               e.printStackTrace();

                                     }

                            }

                   }

         }

}

 

 

 

 

 

 

 

分享到:
评论
13 楼 feng_201 2011-03-16  
谢谢    学习了....
12 楼 ouchxp 2011-03-15  
我晕 LZ标题党. 我是看了"高手进阶"才进来的.
结果进来变成 "菜鸟进阶" 了  我吐...............
11 楼 fatdolphin 2011-03-14  
还是不太明白wait和join的区别,虽说join是为了等待资源而停下来,而wait是无限期堵塞,但是调用join和wait的线程被唤醒有什么区别呢。如果notifyall被调用,那之前调用wait的线程被唤醒,调用join的线程呢?是被唤醒还是继续堵塞中
10 楼 gp00142003 2011-03-14  
进程就像电源插线板,线程就是插板上面的一个个插座。
9 楼 sunnyhui2010 2011-03-14  
学习了一些线程相关的细节,谢了~
8 楼 vigorsoft 2011-03-14  
感谢,学习了。
7 楼 shichuanliujie 2011-03-14  
二胖学习ing。。。
6 楼 libo_591 2011-03-14  
感谢楼主,收获不小
5 楼 xuwenbo 2011-03-14  
赞一个,楼主继续...正好学习学习线程相关
4 楼 huzorro 2011-03-13  
建议看看1.6的多线程特性
3 楼 wqq686 2011-03-13  
<div class="quote_title">158067568 写道</div>
<div class="quote_div">
<p class="MsoNormal" style="margin: 0cm 0cm 0pt;"><span style="font-size: small;"><span>作为有一定开发经验的程序员来说,在</span><span lang="EN-US"><span style="font-family: Times New Roman;">java</span></span><span>中实现多线程是一件很容易的事情,你只需要将你的类继承</span><span lang="EN-US"><span style="font-family: Times New Roman;">Thread</span></span><span>类或者实现</span><span lang="EN-US"><span style="font-family: Times New Roman;">Runnable</span></span><span>接口就可以。<strong>其实线程完全可以理解为一个任务。</strong>可以同时运行多个任务的程序,就成为多线程程序。</span></span></p>
<p class="MsoNormal" style="margin: 0cm 0cm 0pt;"><span><span style="font-size: small;"><span style="color: #ff0000;">然而线程并非进程。<strong>进程包括线程,每一个进程都拥有一套自己的变量,而线程间则共享这套变量。</strong></span>从而带来了很多风险,比如最典型的脏数据。这些以后会讨论。</span></span></p>
</div>
<p>我的理解,进程(Process)与线程(Thread)的区别,是从哪个角度来看的问题,从JAVA的角度,没有进程、线程之分,都是Thread。原因:</p>
<p><a href="http://www.iteye.com/forums/39/topics/954765/java/lang/Thread.html#currentThread()"><strong><span style="font-family: Courier New;">currentThread</span></strong></a><span style="font-family: Courier New;">()</span> Returns a reference to the currently executing thread object.</p>
<p>public class Thread implements Runnable</p>
<p>启动一个JAVA进程,不论在哪里调用Thread.<a href="http://www.iteye.com/forums/39/topics/954765/java/lang/Thread.html#currentThread()"><strong><span style="font-family: Courier New;">currentThread</span></strong></a>()返回的都是当前Thread;</p>
<p>从操作系统的角度来说的,操作系统会区分这个是JAVA进程、那个是IE进程。</p>
<p>从根本上来说,进程与线程的区别在于是否有共享内存空间,以及共享了多少内存空间。对于进程和线程,操作系统的内核不同,可能会有不同的处理方式,比如,Windows和Linux在实现进程和线程就有很大的差异,对于windows来说创建进程比线程开销大,而对于Linux来说两者没有本质区别。</p>
<p><a href="http://stackoverflow.com/questions/807506/threads-vs-processes-in-linux">http://stackoverflow.com/questions/807506/threads-vs-processes-in-linux</a></p>
2 楼 xt19c 2011-03-12  
感谢楼主~继续出进阶二
1 楼 yehengxy 2011-03-12  
感谢楼主 我也学习了

相关推荐

Global site tag (gtag.js) - Google Analytics