java線程實例,java多線程經典案例

本文目錄一覽：

• 1、一個簡單java多線程的示例
• 2、java 由線程名獲取線程實例的方法：
• 3、Java中關於如何實現多線程消息隊列的實例

一個簡單java多線程的示例

for(int i=0;i10;i++){

System.out.println(name+”運行，i=”+i);

Thread.sleep(1)

}

for循環這樣改就行了，因為輸出10個數比較小，當你啟動啟動第二個線程時第一個線程已經運行完畢，所以兩次輸出都是順序輸出，要麼將i設置很大很大，要麼讓每次列印暫停一下

java 由線程名獲取線程實例的方法：

寫個方法：

public Thread getThreadByName(String threadName) {

for (Thread t : Thread.getAllStackTraces().keySet()) {

if (t.getName().equals(threadName)) return t;

}

return null;

}

Java中關於如何實現多線程消息隊列的實例

java中的消息隊列

消息隊列是線程間通訊的手段：

import java.util.*

public class MsgQueue{

private Vector queue = null;

public MsgQueue(){

queue = new Vector();

}

public synchronized void send(Object o)

{

queue.addElement(o);

}

public synchronized Object recv()

{

if(queue.size()==0)

return null;

Object o = queue.firstElement();

queue.removeElementAt(0);//or queue[0] = null can also work

return o;

}

}

因為java中是locked by object的所以添加synchronized 就可以用於線程同步鎖定對象

可以作為多線程處理多任務的存放task的隊列。他的client包括封裝好的task類以及thread類

Java的多線程-線程間的通信2009-08-25 21:58

1. 線程的幾種狀態

線程有四種狀態，任何一個線程肯定處於這四種狀態中的一種：

1) 產生（New）：線程對象已經產生，但尚未被啟動，所以無法執行。如通過new產生了一個線程對象後沒對它調用start()函數之前。

2) 可執行（Runnable）：每個支持多線程的系統都有一個排程器，排程器會從線程池中選擇一個線程並啟動它。當一個線程處於可執行狀態時，表示它可能正處於線程池中等待排排程器啟動它；也可能它已正在執行。如執行了一個線程對象的start()方法後，線程就處於可執行狀態，但顯而易見的是此時線程不一定正在執行中。

3) 死亡（Dead）：當一個線程正常結束，它便處於死亡狀態。如一個線程的run()函數執行完畢後線程就進入死亡狀態。

4) 停滯（Blocked）：當一個線程處於停滯狀態時，系統排程器就會忽略它，不對它進行排程。當處於停滯狀態的線程重新回到可執行狀態時，它有可能重新執行。如通過對一個線程調用wait()函數後，線程就進入停滯狀態，只有當兩次對該線程調用notify或notifyAll後它才能兩次回到可執行狀態。

2. class　Thread下的常用函數函數

2.1 suspend()、resume()

1) 通過suspend()函數，可使線程進入停滯狀態。通過suspend()使線程進入停滯狀態後，除非收到resume()消息，否則該線程不會變回可執行狀態。

2) 當調用suspend()函數後，線程不會釋放它的「鎖標誌」。

例11：

class TestThreadMethod extends Thread{

public static int shareVar = 0;

public TestThreadMethod(String name){

super(name);

}

public synchronized void run(){

if(shareVar==0){

for(int i=0; i5; i++){

shareVar++;

if(shareVar==5){

this.suspend();　//（1）

}}}

else{

System.out.print(Thread.currentThread().getName());

System.out.println(” shareVar = ” + shareVar);

this.resume();　//（2）

}}

}

public class TestThread{

public static void main(String[] args){

TestThreadMethod t1 = new TestThreadMethod(“t1”);

TestThreadMethod t2 = new TestThreadMethod(“t2”);

t1.start();　//（5）

//t1.start();　//（3）

t2.start();　//（4）

}}