<讓我們深入了解一下java線程,以及了解一下為什么需要需要開發(fā)基于線程的應(yīng)用程序>
線程是Java語言的一個部分,而且是Java的最強大的功能之一。究竟什么是線程,為什么要開發(fā)基于線程的應(yīng)用程序?在本文中,我們將深入了解一下線程的用法,以及使用線程的一些技術(shù)。在我們開始講述線程之前,最好先了解一下有關(guān)背景知識和分析一下線程的工作原理。
當(dāng)程序員一開始開發(fā)應(yīng)用程序時,這些應(yīng)用程序只能在一個時間內(nèi)完成一件事情。應(yīng)用程序從主程序開始執(zhí)行,直到運行結(jié)束,像 Fortran/Cobol/Basic這些語言均是如此。
隨著時間的推移,計算機發(fā)展到可以在同一時間段內(nèi)運行不止一個應(yīng)用程序的時代了,但是應(yīng)用程序運行時仍然是串行的,即從開始運行到結(jié)束,下一條指令接著上一條指令執(zhí)行。到最近,程序發(fā)展到可以在執(zhí)行時,以若干個線程的形式運行。Java就具有運行多線程的能力,可以在同一時間段內(nèi)進行幾個操作,這就意味著給定的操作不必等到另外一個操作結(jié)束之后,才能開始。而且對某個操作可以指定更高一級的優(yōu)先級。
不少程序語言,包括ADA, Modula-2和C/C++,已經(jīng)可以提供對線程的支持。同這些語言相比,Java的特點是從最底層開始就對線程提供支持。除此以外,標(biāo)準(zhǔn)的Java類是可重入的,答應(yīng)在一個給定的應(yīng)用程序中由多個線程調(diào)用同一方法,而線程彼此之間又互不干擾。Java的這些特點為多線程應(yīng)用程序的設(shè)計奠定了基礎(chǔ)。
wait(),notify的應(yīng)用一例
本例子實現(xiàn)了兩個線程,每個線程輸出1到100的數(shù)字。
第一個線程輸出1-10,停止,通知第二個線程 輸出1-10 第二個線程停止 通知第一個線程 輸出11-20 ...
實現(xiàn)的要點是
在Java中,每個對象都有個對象鎖標(biāo)志(Object lock flag)與之想關(guān)聯(lián),當(dāng)一個線程A調(diào)用對象的一段synchronized代碼時,
它首先要獲取與這個對象關(guān)聯(lián)的對象鎖標(biāo)志,然后執(zhí)行相應(yīng)的代碼,執(zhí)行結(jié)束后,把這個對象鎖標(biāo)志返回給對象;因此,在線程A執(zhí)行
synchronized代碼期間,假如另一個線程B也要執(zhí)行同一對象的一段synchronized代碼時(不一定與線程A執(zhí)行的相同),它將
要等到線程A執(zhí)行完后,才能繼續(xù)....
如何利用wait() notify() notifyAll()?
在synchronized代碼被執(zhí)行期間,線程可以調(diào)用對象的wait()方法,釋放對象鎖標(biāo)志,進入等待狀態(tài),并且可以調(diào)用notify()或者
notifyAll()方法通知正在等待的其他線程。notify()通知等待隊列中的第一個線程,notifyAll()通知的是等待隊列中的所有線程。
package jdeveloper.study;
/**
* Title: Jdeveloper´s Java PRojdect
* Description: n/a
* Copyright: Copyright (c) 2001
* Company: soho http://www.ChinaJavaWorld.com
* @author jdeveloper@21cn.com
* @version 1.0
*/
import java.lang.Runnable;
import java.lang.Thread;
public class DemoThread implements Runnable{
public DemoThread() {
TestThread testthread1 = new TestThread(this,"1");
TestThread testthread2 = new TestThread(this,"2");
testthread2.start();
testthread1.start();
}
public static void main(String[] args) {
DemoThread demoThread1 = new DemoThread();
}
public void run(){
TestThread t = (TestThread) Thread.currentThread();
try{
if (!t.getName().equalsIgnoreCase("1")) {
synchronized(this) {
wait();
}
}
while(true){
System.out.println("@time in thread"+ t.getName()+ "="+ t.increaseTime());
if(t.getTime()%10 == 0) {
synchronized(this) {
System.out.println("****************************************");
notify();
if ( t.getTime()==100 ) break;
wait();
}
}
}
}catch(Exception e){e.printStackTrace();}
}
}
class TestThread extends Thread{
private int time = 0 ;
public TestThread(Runnable r,String name){
新聞熱點
疑難解答