日韩无码专区无码一级三级片|91人人爱网站中日韩无码电影|厨房大战丰满熟妇|AV高清无码在线免费观看|另类AV日韩少妇熟女|中文日本大黄一级黄色片|色情在线视频免费|亚洲成人特黄a片|黄片wwwav色图欧美|欧亚乱色一区二区三区

這里使用JDK5+的java.util.concurrent包下的API實現(xiàn)，采用這種方式是相對比較安全的。

實現(xiàn)效果：

啟動一個任務(wù)，然后等待任務(wù)的計算結(jié)果同時設(shè)定一個超時時間，如果等待時間超出預(yù)設(shè)定的超時時間，則中止任務(wù)。

代碼實現(xiàn)：

 
 
 

  
  
  
import java.util.concurrent.Callable;    
  
  
  
import java.util.concurrent.ExecutionException;    
  
  
  
import java.util.concurrent.ExecutorService;    
  
  
  
import java.util.concurrent.Executors;    
  
  
  
import java.util.concurrent.Future;    
  
  
  
import java.util.concurrent.TimeUnit;    
  
  
  
import java.util.concurrent.TimeoutException;    
  
  
  
    
  
  
  
/**   
  
  
  
 * 啟動一個任務(wù)，然后等待任務(wù)的計算結(jié)果，如果等待時間超出預(yù)設(shè)定的超時時間，則中止任務(wù)。   
  
  
  
 *    
  
  
  
 * @author Chen Feng   
  
  
  
 */    
  
  
  
public class TaskTimeoutDemo {    
  
  
  
    
  
  
  
    public static void main(String[] args) {    
  
  
  
        System.out.println("Start ...");    
  
  
  
    
  
  
  
        ExecutorService exec = Executors.newCachedThreadPool();    
  
  
  
            
  
  
  
        testTask(exec, 15); // 任務(wù)成功結(jié)束后等待計算結(jié)果，不需要等到15秒    
  
  
  
        testTask(exec, 5); // 只等待5秒，任務(wù)還沒結(jié)束，所以將任務(wù)中止    
  
  
  
    
  
  
  
        exec.shutdown();    
  
  
  
        System.out.println("End!");    
  
  
  
    }    
  
  
  
    
  
  
  
    public static void testTask(ExecutorService exec, int timeout) {    
  
  
  
        MyTask task = new MyTask();    
  
  
  
        Future future = exec.submit(task);    
  
  
  
        Boolean taskResult = null;    
  
  
  
        String failReason = null;    
  
  
  
        try {    
  
  
  
            // 等待計算結(jié)果，最長等待timeout秒，timeout秒后中止任務(wù)    
  
  
  
            taskResult = future.get(timeout, TimeUnit.SECONDS);    
  
  
  
        } catch (InterruptedException e) {    
  
  
  
            failReason = "主線程在等待計算結(jié)果時被中斷！";    
  
  
  
        } catch (ExecutionException e) {    
  
  
  
            failReason = "主線程等待計算結(jié)果，但計算拋出異常！";    
  
  
  
        } catch (TimeoutException e) {    
  
  
  
            failReason = "主線程等待計算結(jié)果超時，因此中斷任務(wù)線程！";    
  
  
  
            exec.shutdownNow();    
  
  
  
        }    
  
  
  
    
  
  
  
        System.out.println("\ntaskResult : " + taskResult);    
  
  
  
       System.out.println("failReason : " + failReason);    
  
  
  
    }    
  
  
  
}    
  
  
  
    
  
  
  
class MyTask implements Callable {    
  
  
  
    
  
  
  
    @Override    
  
  
  
    public Boolean call() throws Exception {    
  
  
  
        // 總計耗時約10秒    
  
  
  
        for (int i = 0; i < 100L; i++) {    
  
  
  
            Thread.sleep(100); // 睡眠0.1秒    
  
  
  
            System.out.print('-');    
  
  
  
        }    
  
  
  
        return Boolean.TRUE;    
  
  
  
    }    
  
  
  
}    
 
 
 

運行結(jié)果：

 
 
 

  
  
  
Start ...    
  
  
  
----------------------------------------------------------------------------------------------------    
  
  
  
taskResult : true    
  
  
  
failReason : null    
  
  
  
---------------------------------------------    
  
  
  
taskResult : null    
  
  
  
failReason : 主線程等待計算結(jié)果超時，因此中斷任務(wù)線程！    
  
  
  
End!   
 
 
 

網(wǎng)站題目：控制Java線程超時后中止的方案
網(wǎng)站網(wǎng)址：http://www.5511xx.com/article/cdjsgpg.html