當前位置:才華齋>計算機>java語言>

Java多執行緒的用法介紹

java語言 閱讀(9.44K)

本文是本站小編搜尋整理的關於Java多執行緒的用法介紹,供參考學習,希望對大家有所幫助!想了解更多相關資訊請持續關注我們應屆畢業生考試網!

Java多執行緒的用法介紹

  1.建立執行緒

在Java中建立執行緒有兩種方法:使用Thread類和使用Runnable介面。在使用Runnable介面時需要建立一個Thread例項。因此,無論是通過Thread類還是Runnable介面建立執行緒,都必須建立Thread類或它的子類的例項。Thread建構函式:

public Thread( );

public Thread(Runnable target);

public Thread(String name);

public Thread(Runnable target, String name);

public Thread(ThreadGroup group, Runnable target);

public Thread(ThreadGroup group, String name);

public Thread(ThreadGroup group, Runnable target, String name);

public Thread(ThreadGroup group, Runnable target, String name, long stackSize);

  方法一:繼承Thread類覆蓋run方法

程式碼如下:

public class ThreadDemo1 {

public static void main(String[] args){

Demo d = new Demo();

t();

for(int i=0;i<60;i++){

tln(entThread()ame()+i);

}

}

}

class Demo extends Thread{

public void run(){

for(int i=0;i<60;i++){

tln(entThread()ame()+i);

}

}

}

  方法二:

程式碼如下:

public class ThreadDemo2 {

public static void main(String[] args){

Demo2 d =new Demo2();

Thread t = new Thread(d);

t();

for(int x=0;x<60;x++){

tln(entThread()ame()+x);

}

}

}

class Demo2 implements Runnable{

public void run(){

for(int x=0;x<60;x++){

tln(entThread()ame()+x);

}

}

}

  2.執行緒的生命週期

與人有生老病死一樣,執行緒也同樣要經歷開始(等待)、執行、掛起和停止四種不同的狀態。這四種狀態都可以通過Thread類中的方法進行控制。下面給出了Thread類中和這四種狀態相關的方法。

// 開始執行緒

publicvoid start( );

publicvoid run( );

// 掛起和喚醒執行緒

publicvoid resume( ); // 不建議使用

publicvoid suspend( ); // 不建議使用

publicstaticvoid sleep(long millis);

publicstaticvoid sleep(long millis, int nanos);

// 終止執行緒

publicvoid stop( ); // 不建議使用

publicvoid interrupt( );

// 得到執行緒狀態

publicboolean isAlive( );

publicboolean isInterrupted( );

publicstaticboolean interrupted( );

// join方法

publicvoid join( ) throws InterruptedException;

執行緒在建立後並不馬上執行run方法中的程式碼,而是處於等待狀態。執行緒處於等待狀態時,可以通過Thread類的方法來設定執行緒不各種屬性,如執行緒的優先順序(setPriority)、執行緒名(setName)和執行緒的型別(setDaemon)等。

當呼叫start方法後,執行緒開始執行run方法中的程式碼。執行緒進入執行狀態。可以通過Thread類的isAlive方法來判斷執行緒是否處於執行狀態。當執行緒處於執行狀態時,isAlive返回true,當isAlive返回false時,可能執行緒處於等待狀態,也可能處於停止狀態。下面的程式碼演示了執行緒的建立、執行和停止三個狀態之間的切換,並輸出了相應的isAlive返回值。

一但執行緒開始執行run方法,就會一直到這個run方法執行完成這個執行緒才退出。但線上程執行的過程中,可以通過兩個方法使執行緒暫時停止執行。這兩個方法是suspend和sleep。在使用suspend掛起執行緒後,可以通過resume方法喚醒執行緒。而使用sleep使執行緒休眠後,只能在設定的時間後使執行緒處於就緒狀態(線上程休眠結束後,執行緒不一定會馬上執行,只是進入了就緒狀態,等待著系統進行排程)。

  在使用sleep方法時有兩點需要注意:

1. sleep方法有兩個過載形式,其中一個過載形式不僅可以設毫秒,而且還可以設納秒(1,000,000納秒等於1毫秒)。但大多數作業系統平臺上的Java虛擬機器都無法精確到納秒,因此,如果對sleep設定了納秒,Java虛擬機器將取最接近這個值的毫秒。

2. 在使用sleep方法時必須使用throws或try{...}catch{...}。因為run方法無法使用throws,所以只能使用try{...}catch{...}。當線上程休眠的過程中,使用interrupt方法中斷執行緒時sleep會丟擲一個InterruptedException異常。sleep方法的定義如下:

publicstaticvoid sleep(long millis) throws InterruptedException

publicstaticvoid sleep(long millis, int nanos) throws InterruptedException

  有三種方法可以使終止執行緒。

1. 使用退出標誌,使執行緒正常退出,也就是當run方法完成後執行緒終止。

2. 使用stop方法強行終止執行緒(這個方法不推薦使用,因為stop和suspend、resume一樣,也可能發生不可預料的'結果)。

3. 使用interrupt方法中斷執行緒。

1. 使用退出標誌終止執行緒

當run方法執行完後,執行緒就會退出。但有時run方法是永遠不會結束的。如在服務端程式中使用執行緒進行監聽客戶端請求,或是其他的需要迴圈處理的任務。在這種情況下,一般是將這些任務放在一個迴圈中,如while迴圈。如果想讓迴圈永遠執行下去,可以使用while(true){...}來處理。但要想使while迴圈在某一特定條件下退出,最直接的方法就是設一個boolean型別的標誌,並通過設定這個標誌為true或false來控制while迴圈是否退出。下面給出了一個利用退出標誌終止執行緒的例子。

join方法的功能就是使非同步執行的執行緒變成同步執行。也就是說,當呼叫執行緒例項的start方法後,這個方法會立即返回,如果在呼叫start方法後後需要使用一個由這個執行緒計算得到的值,就必須使用join方法。如果不使用join方法,就不能保證當執行到start方法後面的某條語句時,這個執行緒一定會執行完。而使用join方法後,直到這個執行緒退出,程式才會往下執行。下面的程式碼演示了join的用法。

  3.多執行緒安全問題

問題原因:當多條語句在操作同一個執行緒共享資料時,一個執行緒對多條語句只執行了一部分,還沒執行完,另一個執行緒參與進來執行,導致共享資料的錯誤。

解決辦法:對多條操作共享資料的語句,只能讓一個執行緒都執行完,在執行過程中,其他執行緒不執行。

同步程式碼塊:

程式碼如下:

public class ThreadDemo3 {

public static void main(String[] args){

Ticket t =new Ticket();

Thread t1 = new Thread(t,"視窗一");

Thread t2 = new Thread(t,"視窗二");

Thread t3 = new Thread(t,"視窗三");

Thread t4 = new Thread(t,"視窗四");

t();

t();

t();

t();

}

}

class Ticket implements Runnable{

private int ticket =400;

public void run(){

while(true){

synchronized (new Object()) {

try {

p(1);

} catch (InterruptedException e) {

// TODO Auto-generated catch block

tStackTrace();

}

if(ticket<=0)

break;

tln(entThread()ame()+"---賣出"+ticket--);

}

}

}

}

  同步函式

程式碼如下:

public class ThreadDemo3 {

public static void main(String[] args){

Ticket t =new Ticket();

Thread t1 = new Thread(t,"視窗一");

Thread t2 = new Thread(t,"視窗二");

Thread t3 = new Thread(t,"視窗三");

Thread t4 = new Thread(t,"視窗四");

t();

t();

t();

t();

}

}

class Ticket implements Runnable{

private int ticket = 4000;

public synchronized void saleTicket(){

if(ticket>0)

tln(entThread()ame()+"賣出了"+ticket--);

}

public void run(){

while(true){

saleTicket();

}

}

}

同步函式鎖是this 靜態同步函式鎖是class

  執行緒間的通訊

程式碼如下:

public class ThreadDemo3 {

public static void main(String[] args){

class Person{

public String name;

private String gender;

public void set(String name,String gender){

=name;

er =gender;

}

public void get(){

tln(+"...."+er);

}

}

final Person p =new Person();

new Thread(new Runnable(){

public void run(){

int x=0;

while(true){

if(x==0){

("張三", "男");

}else{

("lili", "nv");

}

x=(x+1)%2;

}

}

})t();

new Thread(new Runnable(){

public void run(){

while(true){

();

}

}

})t();

}

}

/*

張三....男

張三....男

lili....男

張三

lili....男

*/

  修改上面程式碼

程式碼如下:

public class ThreadDemo3 {

public static void main(String[] args){

class Person{

public String name;

private String gender;

public void set(String name,String gender){

=name;

er =gender;

}

public void get(){

tln(+"...."+er);

}

}

final Person p =new Person();

new Thread(new Runnable(){

public void run(){

int x=0;

while(true){

synchronized (p) {

if(x==0){

("張三", "男");

}else{

("lili", "nv");

}

x=(x+1)%2;

}

}

}

})t();

new Thread(new Runnable(){

public void run(){

while(true){

synchronized (p) {

();

}

}

}

})t();

}

}

/*

張三....男

張三....男

張三....男

張三....男

*/