Java语法总结 - 线程

上一篇 / 下一篇  2009-03-24 22:58:03 / 个人分类:Java Thread

  • 文件版本: V1.0
  • 开发商: 本站原创
  • 文件来源: 本地
  • 界面语言: 简体中文
  • 授权方式: 免费
  • 运行平台: Win9X/Win2000/WinXP
  一提到线程好像是件很麻烦很复杂的事,事实上确实如此,涉及到线程的编程是很讲究技巧的。这就需要我们变换思维方式,了解线程机制的比较通用的技巧,写出高效的、不依赖于某个JVM实现的程序来。毕竟仅仅就Java而言,各个虚拟机的实现是不同的。学习线程时,最令我印象深刻的就是那种不确定性、没有保障性,各个线程的运行完全是以不可预料的方式和速度推进,有的一个程序运行了N次,其结果差异性很大。
3J-urL*~1~+kWk:t01、什么是线程?线程是彼此互相独立的、能独立运行的子任务,并且每个线程都有自己的调用栈。所谓的多任务是通过周期性地将CPU时间片切换到不同的子任务,虽然从微观上看来,单核的CPU上同时只运行一个子任务,但是从宏观来看,每个子任务似乎是同时连续运行的。(但是JAVA的线程不是按时间片分配的,在本文的最后引用了一段网友翻译的JAVA原著中对线程的理解。)51Testing软件测试网(S+Uz)pAV^
2、在java中,线程指两个不同的内容:一是java.lang.Thread类的一个对象;另外也可以指线程的执行。线程对象和其他的对象一样,在堆上创建、运行、死亡。但不同之处是线程的执行是一个轻量级的进程,有它自己的调用栈。
c kSLdLw0可以这样想,每个调用栈都对应一个线程,每个线程又对应一个调用栈。51Testing软件测试网 G#H Z'vXDg.E
我们运行java程序时有一个入口函数main()函数,它对应的线程被称为主线程。一个新线程一旦被创建,就产生一个新调用栈,从原主线程中脱离,也就是与主线程并发执行。
&nKX-XS)S_{h2az04、当提到线程时,很少是有保障的。我们必须了解到什么是有保障的操作,什么是无保障的操作,以便设计的程序在各种jvm上都能很好地工作。比如,在某些jvm实现中,把java线程映射为本地操作系统的线程。这是java核心的一部分。
$v2@%m0x7A05、线程的创建。
7^3b aN`%z k'w0创建线程有两种方式:
'D6w5uvG/H k0A、继承java.lang.Thread类。
v,G-o:pk/V+lR K0    class ThreadTest extends Thread{
3ga6E;Q4T|C0        public void run() {
0^'k#B"[ Xk0            System.out.println ("someting run here!");51Testing软件测试网Am0P q1m nxn3R:\[,u
        }51Testing软件测试网"Og_!FeV3@,w
        public void run(String s){51Testing软件测试网6c)}!zq&]q
            System.out.println ("string in run is " + s);
#Ur3IR1_$N.U*e \M{/{$l r0        }51Testing软件测试网*Fh%hVwo$Bi
        public static void main (String[] args) {51Testing软件测试网;\'q Nv\\ H
            ThreadTest tt = new ThreadTest();51Testing软件测试网Y0~}Z"N Tf
            tt.start();
;nRE]e:E r)pH%m0            tt.run("it won't auto run!");51Testing软件测试网+t*\_'e2A
        }51Testing软件测试网3o)v g,Gce~Ekp
    }51Testing软件测试网 @ Hz1E8Y*}7Wmu
51Testing软件测试网(O.W~jp x$sP }
输出的结果比较有趣:
[X6b6|Lmr.w g[7o0string in run is it won't auto run!
v }R[kT0W K0~#ki0someting run here!
'^2ev^| DvD \0注意输出的顺序:好像与我们想象的顺序相反了!为什么呢?51Testing软件测试网xN&eh;Xkl I
一旦调用start()方法,必须给JVM点时间,让它配置进程。而在它配置完成之前,重载的run(String s)方法被调用了,结果反而先输出了“string in run is it won't auto run!”,这时tt线程完成了配置,输出了“someting run here!”。
qc*HkcB/E.W0这个结论是比较容易验证的:51Testing软件测试网,Be1`!G5wSTT3U.D
修改上面的程序,在tt.start();后面加上语句for (int i = 0; i<10000; i++); 这样主线程开始执行运算量比较大的for循环了,只有执行完for循环才能运行后面的tt.run("it won't auto run!");语句。此时,tt线程和主线程并行执行了,已经有足够的时间完成线程的配置!因此先到一步!修改后的程序运行结果如下:
)z[].Adzn.D0|-zW0someting run here!51Testing软件测试网0|-[/B1W#z+H4~)x
string in run is it won't auto run!51Testing软件测试网X7j HU/`V+v+x3N6K$Y
注意:这种输出结果的顺序是没有保障的!不要依赖这种结论!51Testing软件测试网 i(}[;?9d@%I
没有参数的run()方法是自动被调用的,而带参数的run()是被重载的,必须显式调用。51Testing软件测试网W a3tk'{3`S
这种方式的限制是:这种方式很简单,但不是个好的方案。如果继承了Thread类,那么就不能继承其他的类了,java是单继承结构的,应该把继承的机会留给别的类。除非因为你有线程特有的更多的操作。51Testing软件测试网2SC7G%W2}4Oa-P
Thread类中有许多管理线程的方法,包括创建、启动和暂停它们。所有的操作都是从run()方法开始,并且在run()方法内编写需要在独立线程内执行的代码。run()方法可以调用其他方法,但是执行的线程总是通过调用run()。51Testing软件测试网Z!K\(~6IX
51Testing软件测试网M{WC5?C(} Z$^
B、实现java.lang.Runnable接口。
J!^b~-[:H0    class ThreadTest implements Runnable {
&\;w9`;P2P0        public void run() {
Q7nT4^-r(Ck0            System.out.println ("someting run here");51Testing软件测试网(NG.X"lh5\!{
        }
q X sJ`X0        public static void main (String[] args) {51Testing软件测试网 H-P0As/g`@)kJU
            ThreadTest tt = new ThreadTest();
8rZ7]%bQ Iw0        Thread t1 = new Thread(tt);51Testing软件测试网,RhJ[f1@ p B~ W
        Thread t2 = new Thread(tt);
#^S$Uq%Cf)C+z0        t1.start();51Testing软件测试网F1^tI~
        t2.start();
iHHI:Pe(A:y0            //new Thread(tt).start();
A.iG6~~#M [ r/` y0        }51Testing软件测试网)v:CJ0c1JQj
    }
MO`qY _!~051Testing软件测试网5F#^;G\9IU
比第一种方法复杂一点,为了使代码被独立的线程运行,还需要一个Thread对象。这样就把线程相关的代码和线程要执行的代码分离开来。51Testing软件测试网G H9TT8U yD1e&ro i
另一种方式是:参数形式的匿名内部类创建方式,也是比较常见的。51Testing软件测试网v-`#{&iLs
    class ThreadTest{
'Xo2EX(L1E0        public static void main (String[] args) {51Testing软件测试网-Wz X^9L0F
            Thread t = new Thread(new Runnable(){51Testing软件测试网5p)z&I.B9h z-Q
                public void run(){51Testing软件测试网i3\6fCsM h
                    System.out.println ("anonymous thread");51Testing软件测试网4kWaG!]Z c6H
                }
O:a{P|T+tA5h3b0            });    51Testing软件测试网m"@4T$S$]s;|
            
Tz,E'Cr:N|]D0            t.start();
Z6j[AP0        }
r)]l(cq n5U0    }
;Ywkqrq Fz!^0如果你对此方式的声明不感冒,请参看本人总结的内部类。
!w"CX4}5b;?q[ Q0第一种方式使用无参构造函数创建线程,则当线程开始工作时,它将调用自己的run()方法。51Testing软件测试网5h"DxoN4zZ WH1|
第二种方式使用带参数的构造函数创建线程,因为你要告诉这个新线程使用你的run()方法,而不是它自己的。51Testing软件测试网!O*sa-W1R6F5~g
如上例,可以把一个目标赋给多个线程,这意味着几个执行线程将运行完全相同的作业。
Q#jG#{p1RgA06、什么时候线程是活的?
5?ph_-YBQ0在调用start()方法开始执行线程之前,线程的状态还不是活的。测试程序如下:51Testing软件测试网X%{l8V&~0b
    class ThreadTest implements Runnable {
4t z0vD_0        public void run() {51Testing软件测试网@1tu!G#ywNsn
            System.out.println ("someting run here");51Testing软件测试网x[)O*Z8Ty U
        }
Kh,l.JN+I7j5F0        public static void main (String[] args) {51Testing软件测试网._,?~'x3u p
            ThreadTest tt = new ThreadTest();
R J C5[S} F0            Thread t1 = new Thread(tt);
N*owFyHP8l1]j8A0            System.out.println (t1.isAlive());51Testing软件测试网%J2P_1ZD,tx&s$g
            t1.start();51Testing软件测试网Hq-m)n/K z&{4`
            System.out.println (t1.isAlive());
vZ H?i/p0        }51Testing软件测试网2|FuJ`&v1w
    }51Testing软件测试网5k g\U5o` [9N

Ro6BM3Z7b0结果输出:51Testing软件测试网9|,L%SSNe)`2z hq
false
UM8nkL\0true51Testing软件测试网 E B(feZ F@!]'I
isAlive方法是确定一个线程是否已经启动,而且还没完成run()方法内代码的最好方法。51Testing软件测试网:AYUk%YQqY
7、启动新线程。
q{L.Z wQ0线程的启动要调用start()方法,只有这样才能创建新的调用栈。而直接调用run()方法的话,就不会创建新的调用栈,也就不会创建新的线程,run()方法就与普通的方法没什么两样了!51Testing软件测试网2m%f#A)R \
8、给线程起个有意义的名字。51Testing软件测试网1}$Ib~S
没有该线程命名的话,线程会有一个默认的名字,格式是:“Thread-”加上线程的序号,如:Thread-0
H YV xL%dHio0这看起来可读性不好,不能从名字分辨出该线程具有什么功能。下面是给线程命名的方式。51Testing软件测试网9P+@4z/q]0PH,g
第一种:用setName()函数51Testing软件测试网:p!i ^h"[Nv0Z$V7v
第二种:选用带线程命名的构造器
.MM y[0|lO%Qu"C0    class ThreadTest implements Runnable{
[Y$y8Z2xc LgQ0d R0        public void run(){
4g#O._q[ ?A?$s0            System.out.println (Thread.currentThread().getName());51Testing软件测试网2\$J/y5rRcT G
        }51Testing软件测试网yp4Vh{P:J3aON
        public static void main (String[] args) {51Testing软件测试网 KK} a p[Z
        ThreadTest tt = new ThreadTest();     
weO%J"E!zR0        //Thread t = new Thread (tt,"eat apple");51Testing软件测试网#IL x-J$TTn/I }!z
        Thread t = new Thread (tt);
-O;B J3C7M)p0        t.setName("eat apple");51Testing软件测试网&q.x \2v(_'zvX
        t.start();
%E_5[a-j n/@!RG#q0        }51Testing软件测试网G.Ox OEni GEa
    }51Testing软件测试网AO%? R){&^"g
9、“没有保障”的多线程的运行。下面的代码可能令人印象深刻。
So4S*@[6A0    class ThreadTest implements Runnable{51Testing软件测试网y.pHo_6Fz
        public void run(){
v&G j_yQ0            System.out.println (Thread.currentThread().getName());51Testing软件测试网r;Q%y;S.Y:s\
        }
/mi)VM.^K O1^4L.I$U0        public static void main (String[] args) {51Testing软件测试网d:]+Km:WbH
            ThreadTest tt = new ThreadTest();51Testing软件测试网/Z {fJ8v|/n
            Thread[] ts =new Thread[10];51Testing软件测试网6V!fCrK,^C3U^
        51Testing软件测试网,t?;jfa"B{:b
            for (int i =0; i < ts.length; i++)
+W J5~ XG]4q/D0                ts[i] = new Thread(tt);51Testing软件测试网`+HJn J M
                51Testing软件测试网:e!mJ;mJe
            for (Thread t : ts)
!~$O rPea5q0F(L}0                t.start();
Wz0p%Z)O5x0        }51Testing软件测试网$N-E&Z)c lU,lpC_L
    }
q!c+pNae0在我的电脑上运行的结果是:51Testing软件测试网QHK~ T&zFo
Thread-0
2c`k_8J;c6k0Thread-1
xld/W@0Thread-351Testing软件测试网/R7^S Lp HFWP?#\D
Thread-5
K-qh,] ~k0Thread-251Testing软件测试网$n!~&uu7aj8l6c
Thread-7
Sh Vgx xW0Thread-451Testing软件测试网0~nrl.?
Thread-951Testing软件测试网8N m&l^Qj B
Thread-6
/P|Y jdt0Thread-851Testing软件测试网#L*m x_v'y
而且每次运行的结果都是不同的!继续引用前面的话,一旦涉及到线程,其运行多半是没有保障。这个保障是指线程的运行完全是由调度程序控制的,我们没法控制它的执行顺序,持续时间也没有保障,有着不可预料的结果。51Testing软件测试网+]l7z@u\,l9i
10、线程的状态。
5L-w9h?,i K0A、新状态。51Testing软件测试网 j#a1II8H8H%LK
实例化Thread对象,但没有调用start()方法时的状态。51Testing软件测试网@!Ee VW,P?AA
ThreadTest tt = new ThreadTest();     
$S'Jly(dF0或者Thread t = new Thread (tt);51Testing软件测试网}5q5r_PFG8? S
此时虽然创建了Thread对象,如前所述,但是它们不是活的,不能通过isAlive()测试。51Testing软件测试网2l%{~ g7Xd
B、就绪状态。51Testing软件测试网A3`+fF*P
线程有资格运行,但调度程序还没有把它选为运行线程所处的状态。也就是具备了运行的条件,一旦被选中马上就能运行。
/KPK"\;H8Q$g,Rt4[@0也是调用start()方法后但没运行的状态。此时虽然没在运行,但是被认为是活的,能通过isAlive()测试。而且在线程运行之后、或者被阻塞、等待或者睡眠状态回来之后,线程首先进入就绪状态。51Testing软件测试网(h1eFd T+X v,[ ?
C、运行状态。51Testing软件测试网L^ |3iMk
从就绪状态池(注意不是队列,是池)中选择一个为当前执行进程时,该线程所处的状态。51Testing软件测试网d%tLf E| ct
D、等待、阻塞、睡眠状态。
w|Y$Zz5du0这三种状态有一个共同点:线程依然是活的,但是缺少运行的条件,一旦具备了条就就可以转为就绪状态(不能直接转为运行状态)。另外,suspend()和stop()方法已经被废弃了,比较危险,不要再用了。51Testing软件测试网7u1O&YP&| BW
E、死亡状态。51Testing软件测试网-sMSGqU
一个线程的run()方法运行结束,那么该线程完成其历史使命,它的栈结构将解散,也就是死亡了。但是它仍然是一个Thread对象,我们仍可以引用它,就像其他对象一样!它也不会被垃圾回收器回收了,因为对该对象的引用仍然存在。51Testing软件测试网 ~+W{ |g2@ gB.?#M9j C
如此说来,即使run()方法运行结束线程也没有死啊!事实是,一旦线程死去,它就永远不能重新启动了,也就是说,不能再用start()方法让它运行起来!如果强来的话会抛出IllegalThreadStateException异常。如:51Testing软件测试网!u3G ITu`'f5V
t.start();51Testing软件测试网4fa;a+Y]0]4n
t.start();51Testing软件测试网(gHR%C!D
放弃吧,人工呼吸或者心脏起搏器都无济于事……线程也属于一次性用品。51Testing软件测试网/i'UbLq^tde
11、阻止线程运行。
'?AIk)C0A、睡眠。sleep()方法
W\G5x(y/]D"f%Dz'J0让线程睡眠的理由很多,比如:认为该线程运行得太快,需要减缓一下,以便和其他线程协调;查询当时的股票价格,每睡5分钟查询一次,可以节省带宽,而且即时性要求也不那么高。
O&k2c'z%Q8t%M ~-rL QU0用Thread的静态方法可以实现Thread.sleep(5*60*1000); 睡上5分钟吧。sleep的参数是毫秒。但是要注意sleep()方法会抛出检查异常InterruptedException,对于检查异常,我们要么声明,要么使用处理程序。
5b+p!p\KG3n@0    try {51Testing软件测试网)iwOu)s
        Thread.sleep(20000);
2a4P-s"ey0    }
.KYP(s`7Hyf0    catch (InterruptedException ie) {51Testing软件测试网9I2XBh f3J@9\7U
        ie.printStackTrace();
.O ZU2}Z*^0    }
WMW@S9b2Y7Q wLJ0既然有了sleep()方法,我们是不是可以控制线程的执行顺序了!每个线程执行完毕都睡上一觉?这样就能控制线程的运行顺序了,下面是书上的一个例子:51Testing软件测试网$w7_3w} uX&D*P vI
    class ThreadTest implements Runnable{
Pt aEC v pnf0        public void run(){51Testing软件测试网2l6[ n(q"s_
            for (int i = 1; i<4; i++){51Testing软件测试网$DDQ U(D;}2k-~
                System.out.println (Thread.currentThread().getName());
js?#R6Xz0                try {
\u}YAgI0                    Thread.sleep(1000);51Testing软件测试网'Y ko d6Y3G
                } catch (InterruptedException ie) { }51Testing软件测试网 i#r0].o?2]9u~1]
            }
QGDsH9J$d0        }
U#S4UbJ0        public static void main (String[] args) {
1F"Jts5w9dl0            ThreadTest tt = new ThreadTest();
!lhky2o/P3mT[u0            Thread t0 = new Thread(tt,"Thread 0");
4S+{/|!k6e0            Thread t1 = new Thread(tt,"Thread 1");
WN Q+u^Q5|:N0            Thread t2 = new Thread(tt,"Thread 2");51Testing软件测试网!r-Yrxc0lzl
            t0.start();
KPk4u-q X AaX0            t1.start();51Testing软件测试网Yt?S"aYsN
            t2.start();            
3pD.ge9@;Hm0        }51Testing软件测试网7RR,ni8q$u[ e9Y0@(q
    }51Testing软件测试网R,cG7?3S M hYj
51Testing软件测试网Z\'~$tc#^x9U} D
并且给出了结果:51Testing软件测试网3s6f;s5D*U
Thread 051Testing软件测试网,L~.s-u@/s%cQ B;IF
Thread 151Testing软件测试网NA]H#N*U6\
Thread 2
Y7X Z%e!N)a0Thread 0
T(g8V1_dc+Jtp0Thread 1
E7Zwi&k)k D'A%Ci0Thread 251Testing软件测试网~*vp1OS*T%o
Thread 0
J/u2G2zpFn3C`0Thread 151Testing软件测试网(b?E[ R)\
Thread 251Testing软件测试网W:I!@1u7Y6wNu
也就是Thread 0  Thread 1 Thread 2 按照这个顺序交替出现,作者指出虽然结果和我们预料的似乎相同,但是这个结果是不可靠的。果然被我的双核电脑验证了:51Testing软件测试网 H T4|HJa~3Tr
Thread 0
$SgL6N/^&t!C9w0Thread 151Testing软件测试网WI CH qCLxn
Thread 2
/f3MXn3E-B0Thread 251Testing软件测试网IJR tW
Thread 051Testing软件测试网i E"Dr`??A0k w l
Thread 1
wBg"WPC1Ln0Thread 151Testing软件测试网$Um~&Hv9~HXv t
Thread 051Testing软件测试网'tBN8bUa
Thread 251Testing软件测试网 Gl eV;K
看来线程真的很不可靠啊。但是尽管如此,sleep()方法仍然是保证所有线程都有运行机会的最好方法。至少它保证了一个线程进入运行之后不会一直到运行完位置。
'}T"n3L^n8~FbY(P0时间的精确性。再强调一下,线程醒来之后不会进入运行状态,而是进入就绪状态。因此sleep()中指定的时间不是线程不运行的精确时间!不能依赖sleep()方法提供十分精确的定时。我们可以看到很多应用程序用sleep()作为定时器,而且没什么不好的,确实如此,但是我们一定要知道sleep()不能保证线程醒来就能马上进入运行状态,是不精确的。51Testing软件测试网4FQ4CF^0oA y
sleep()方法是一个静态的方法,它所指的是当前正在执行的线程休眠一个毫秒数。看到某些书上的Thread.currentThread().sleep(1000); ,其实是不必要的。Thread.sleep(1000);就可以了。类似于getName()方法不是静态方法,它必须针对具体某个线程对象,这时用取得当前线程的方法Thread.currentThread().getName();
!cH3Fi/fv)G[0B、线程优先级和让步。51Testing软件测试网{j;M.B%Xt1P
线程的优先级。在大多数jvm实现中调度程序使用基于线程优先级的抢先调度机制。如果一个线程进入可运行状态,并且它比池中的任何其他线程和当前运行的进程的具有更高的优先级,则优先级较低的线程进入可运行状态,最高优先级的线程被选择去执行。51Testing软件测试网nF-zqkAUI
于是就有了这样的结论:当前运行线程的优先级通常不会比池中任何线程的优先级低。但是并不是所有的jvm的调度都这样,因此一定不能依赖于线程优先级来保证程序的正确操作,这仍然是没有保障的,要把线程优先级用作一种提高程序效率的方法,并且这种方法也不能依赖优先级的操作。51Testing软件测试网 X?1wv~%vu7IPL
另外一个没有保障的操作是:当前运行的线程与池中的线程,或者池中的线程具有相同的优先级时,JVM的调度实现会选择它喜欢的线程。也许是选择一个去运行,直至其完成;或者用分配时间片的方式,为每个线程提供均等的机会。51Testing软件测试网C _.r;LPu_(L(C,g!\
优先级用正整数设置,通常为1-10,JVM从不会改变一个线程的优先级。默认情况下,优先级是5。Thread类具有三个定义线程优先级范围的静态最终常量:Thread.MIN_PRIORITY (为1) Thread.NORM_PRIORITY (为5) Thread.MAX_PRIORITY (为10)
~t'B&z4L0静态Thread.yield()方法。51Testing软件测试网N~7E*t O4h!m2t
它的作用是让当前运行的线程回到可运行状态,以便让具有同等优先级的其他线程运行。用yield()方法的目的是让同等优先级的线程能适当地轮转。但是,并不能保证达到此效果!因为,即使当前变成可运行状态,可是还有可能再次被JVM选中!也就是连任。
*[h'D2r6{MH0非静态join()方法。51Testing软件测试网"F3ln \$K e/L
让一个线程加入到另一个线程的尾部。让B线程加入A线程,意味着在A线程运行完成之前,B线程不会进入可运行状态。
#ct,p!~ jVK&E$B`!|0    Thread t = new Thread();51Testing软件测试网mBWp u
    t.start();51Testing软件测试网!l'dS.j/eUJ0M
    t.join;51Testing软件测试网J8uvV,V@
这段代码的意思是取得当前的线程,把它加入到t线程的尾部,等t线程运行完毕之后,原线程继续运行。

TAG:

 

评分:0

我来说两句

Open Toolbar