大家知道, 在我们写多线程的时候, 往往要Extends Thread来实现一个线程, 通过覆盖Run()来改写start()方法, 在很多情况下, 我们还有可能用implements Runnable来实现一个线程,他们有什么区别?
让我们来看一个例子:假设我们需要实现一个对象, 每个一段时间来检测一个服务器的端口是否还在活动,我们编写一个对象, 如下代码:
package com.collegesoft;
import java.net.URL;
import java.net.HttpURLConnection;
import java.io.*;
import java.net.*;
public class SendMsg extends Thread {
public final static int SYSISOK=1;
public final static int SYSISDOWN=-1;
public final static int SYSISOUTOFTIME=0;
public final static int SYSISEXCEPTION=-3;
String testURL;
private URL url;
boolean needStop=false;
/**
* 读取是否需要停止主线程
* @return 停止标志符
*/
public synchronized boolean getNeedStop(){
return needStop;
}
/**
* 设置是否需要停止主线程 , 如果在外部调用 改线程的start()方法, 可以使用setNeedStop(true)来停止
* @param b 停止标志符
*/
public synchronized void setNeedStop(boolean b){
needStop=b;
}
/**
* 构造器
* @param testURL 要检测的URL
*/
public SendMsg(String testURL){
this.testURL =testURL;
}
/**
* 被检测系统的状态
*/
private int sysState=0;
/**
* 设置被检测系统的状态, 也可用于清零复位处理
* @param state 即将设置的状态。
*/
public synchronized void setSysState(int state){
System.out.println("set state ="+state);
this.sysState =state;
}
/**
* 返回被检测系统的当前状态
* @return 被检测系统的当前状态 0:无响应, 1:正常, -1:当机 ,-3 :其他错误
*/
public synchronized int getSysState(){
return sysState;
}
public void run(){
while (!needStop ){
new TestURLThread(this).start() ;
synchronized (this){
try{
this.wait(30*1000);
}catch(InterruptedException e) {
}
if (getSysState() == SYSISOK ) {
System.out.println("一切正常");
}
else if (getSysState() == SYSISDOWN ) {
System.out.println("系统荡机");
}
else if(getSysState()==SYSISOUTOFTIME ){
System.out.println("系统长时间无响应");
}else{
System.out.println("系统发生其他错误");
}
}
}
}
public static void main(String[] args) {
new SendMsg("http://www.163.com").start();
}
/*************************************************************************
* 内部类开始
************************************************************************/
class TestURLThread extends Thread{
SendMsg sendSmg=null;
TestURLThread(SendMsg send ){
sendSmg =send;
}
/**
* 作为Thread继承类 , 覆盖父类run方法
*/
public void run(){
//先复位
setSysState(sendSmg.SYSISOUTOFTIME);
HttpURLConnection httpCon = null;
String results ;
try {
url = new URL(testURL);
httpCon = (HttpURLConnection) url.openConnection();
BufferedReader in = new BufferedReader(new InputStreamReader(httpCon.getInputStream()));
results = in.readLine();
httpCon.disconnect();
setSysState(sendSmg.SYSISOK );
/**
* 如果你不希望立即通知 sendSmg线程, 一下同步体可以去除!
*/
synchronized (sendSmg){
sendSmg.notify();
System.out.println("notify sendSMG");
}
}
catch (ConnectException ex) {
//如果建立连接异常,表示系统已断
setSysState(sendSmg.SYSISDOWN );
/**
* 如果你不希望立即通知 sendSmg线程, 一下同步体可以去除!
*/
synchronized (sendSmg){
sendSmg.notify();
}
}
catch (Exception ex) {
setSysState(sendSmg.SYSISEXCEPTION);
/**
* 如果你不希望立即通知 sendSmg线程, 一下同步体可以去除!
*/
synchronized (sendSmg){
sendSmg.notify();
}
}
finally {
if (httpCon != null) {
httpCon.disconnect();
httpCon = null;
}
}
}
}
/*************************************************************************
* 内部类结束
************************************************************************/
}
我们在这个例子中, 用TestURLThread来测试163网站的80端口, 一旦有结果就notify() SendMsg线程的wait()方法, 不至于让他傻傻的等,现在的问题是, 我们是否可以将 TestURLThread不重Thread继承, 而是扩展Runnable接口来实现, 在SendMsg中用
new TestURLThread(this).run() ;来调用TestURLThread的run()方法?
答案是否定的
因为, 一旦替换成Runnable之后, 在TestURLThread的run里面, sendMSsg.notify()将不能及时唤醒SendMsg的wait(),只能靠 this.wait(30*1000);来退出等待。
这是我发现现象后得出的结论, 希望网友讨论, 是否有道理, 或者理由是什么