多線程是java的一個優(yōu)勢,java使得程序員可以很方便的進(jìn)行多線程程序開發(fā)。獲得更好的性能。
關(guān)于多線程的概念以及一般的多線程編程,比如如何以及為何實現(xiàn)runnable接口,為何stop()會被Deprecated掉等等,這個請看matrix之前的多線程編程基礎(chǔ)或者sun的java文檔。
關(guān)于多線程編程,有幾點這里要提到的:
1。既然stop()是不被推薦的,那么我們?nèi)绾瓮V挂粋€線程呢?直接kill嗎?在這里,筆者總結(jié)一種比較通用也比較穩(wěn)定的方法:
class threadtest extend Thread{
//skip some code..
boolean runflag=true;
public synchronized void stopthread()
{
runflag=false;
}
public synchronized boolean getrunflag()
{
return runflag;
}
public void run() {
runflag=true;
try {
while (getrunflag()) {
code1;
code2;
//put your code here
}
}
}
catch (IOException e) {
e.printStackTrace();
}
System.out.println(this.getClass().getName()+" stopped");
}
//skip some code..
}
這樣,每當(dāng)需要停止該線程時,只需調(diào)用stopthread()即可。
這里有兩點需要注意:
1)我們用了一個同步方法getrunflag()來得到當(dāng)前的狀態(tài),為什么用這個方法而不是直接使用while(runflag)呢?
這個是因為在java的多線程模型中,有一個公共的對象存儲區(qū),但是每個對象都有自己的私有備份,當(dāng)一個線程改變了狀態(tài),jvm并不能保證這個線程改變過的變量即時更新公共對象存儲區(qū)的狀態(tài),可能(可能性不大)造成問題。
所以建議有好的設(shè)計習(xí)慣,采用同步方法來獲得當(dāng)前的runflag值。
2)還有一點,特別是涉及網(wǎng)絡(luò)的多線程,如果發(fā)生了網(wǎng)絡(luò)阻塞(在while循環(huán)里面發(fā)生),那么,即使runflag狀態(tài)比如改變成false,由于程序被阻塞,線程用這種方法是永遠(yuǎn)都不會被停止的。
舉個例子:比如上面的程序,如果code1是一段網(wǎng)絡(luò)程式,如果在code1發(fā)生了阻塞,阻塞的意義就是得不到請求的
資源,在無限期等待,這個時候,runflag狀態(tài)的變化對while循環(huán)是起不了作用的,線程不會被停止。
筆者曾經(jīng)參與多個涉及到獲取網(wǎng)絡(luò)資源的java程式,經(jīng)常遇到因為網(wǎng)絡(luò)的阻塞引起的線程問題。
如果你的程式可能涉及到網(wǎng)絡(luò)阻塞,或者有可能發(fā)生某種消息接受的阻塞。那么,請不要用這種方法來停止線程。具體方法請看筆者另外一片文章:高級多線程編程(二)-多線程中的監(jiān)控與超時問題。
關(guān)于多線程的概念以及一般的多線程編程,比如如何以及為何實現(xiàn)runnable接口,為何stop()會被Deprecated掉等等,這個請看matrix之前的多線程編程基礎(chǔ)或者sun的java文檔。
關(guān)于多線程編程,有幾點這里要提到的:
1。既然stop()是不被推薦的,那么我們?nèi)绾瓮V挂粋€線程呢?直接kill嗎?在這里,筆者總結(jié)一種比較通用也比較穩(wěn)定的方法:
class threadtest extend Thread{
//skip some code..
boolean runflag=true;
public synchronized void stopthread()
{
runflag=false;
}
public synchronized boolean getrunflag()
{
return runflag;
}
public void run() {
runflag=true;
try {
while (getrunflag()) {
code1;
code2;
//put your code here
}
}
}
catch (IOException e) {
e.printStackTrace();
}
System.out.println(this.getClass().getName()+" stopped");
}
//skip some code..
}
這樣,每當(dāng)需要停止該線程時,只需調(diào)用stopthread()即可。
這里有兩點需要注意:
1)我們用了一個同步方法getrunflag()來得到當(dāng)前的狀態(tài),為什么用這個方法而不是直接使用while(runflag)呢?
這個是因為在java的多線程模型中,有一個公共的對象存儲區(qū),但是每個對象都有自己的私有備份,當(dāng)一個線程改變了狀態(tài),jvm并不能保證這個線程改變過的變量即時更新公共對象存儲區(qū)的狀態(tài),可能(可能性不大)造成問題。
所以建議有好的設(shè)計習(xí)慣,采用同步方法來獲得當(dāng)前的runflag值。
2)還有一點,特別是涉及網(wǎng)絡(luò)的多線程,如果發(fā)生了網(wǎng)絡(luò)阻塞(在while循環(huán)里面發(fā)生),那么,即使runflag狀態(tài)比如改變成false,由于程序被阻塞,線程用這種方法是永遠(yuǎn)都不會被停止的。
舉個例子:比如上面的程序,如果code1是一段網(wǎng)絡(luò)程式,如果在code1發(fā)生了阻塞,阻塞的意義就是得不到請求的
資源,在無限期等待,這個時候,runflag狀態(tài)的變化對while循環(huán)是起不了作用的,線程不會被停止。
筆者曾經(jīng)參與多個涉及到獲取網(wǎng)絡(luò)資源的java程式,經(jīng)常遇到因為網(wǎng)絡(luò)的阻塞引起的線程問題。
如果你的程式可能涉及到網(wǎng)絡(luò)阻塞,或者有可能發(fā)生某種消息接受的阻塞。那么,請不要用這種方法來停止線程。具體方法請看筆者另外一片文章:高級多線程編程(二)-多線程中的監(jiān)控與超時問題。