淺談java中異步多執行緒超時導致的服務異常

在專案中為了提高大並發量時的效能穩定性，常常會使用到執行緒池來做多執行緒非同步操作，多執行緒有2種，一種是實現runnable接口，這種沒有回傳值，一種是實作Callable接口，這種有回傳值。

當其中一個執行緒逾時的時候，理論上應該不 影響其他執行緒的執行結果，但是在專案中出現的問題表示一個執行緒阻塞，其他執行緒回傳的介面都為空。其實是個很簡單的問題，但因為第一次碰到，還是想了一些時間的。很簡單，就是因為阻塞的那個線

程沒有釋放，並發量一大，線程池數量就滿了，所以其他線程都處於等待狀態。

附上一段自己寫的調試程式碼，當想不出問題的時候，自己模擬的寫寫，說不定問題就出來了。

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;
 
public class FutureTest
{
 
  public static void main(String[] args) throws InterruptedException,
    ExecutionException, TimeoutException
  {
 
    final ExecutorService exec = Executors.newFixedThreadPool(1);
     
 
    Callable<String> call = new Callable<String>() {
      public String call() throws InterruptedException
      {
        // 开始执行耗时操作
          Thread.sleep(1000 * 2); 
        return "1线程执行完成.";
      }
    };
 
    Callable<String> call2 = new Callable<String>() {
      public String call() throws Exception
      {
        // 开始执行耗时操作
        // Thread.sleep(1000 * 5);
        return "2线程执行完成.";
      }
    };
     
    Callable<String> call3 = new Callable<String>() {
      public String call() throws Exception
      {
        // 开始执行耗时操作
        // Thread.sleep(1000 * 5);
        return "3线程执行完成.";
      }
    };
 
    Future<String> future = exec.submit(call);
    Future<String> future3 = exec.submit(call3);
     Future<String> future2 = exec.submit(call2);
      String obj="";
      String obj2 ="";
      String obj3 ="";
      try{
       obj = future.get(500, TimeUnit.MILLISECONDS); // 任务处理超时时间设为
      }// 1 秒
      catch(Exception e){
        System.out.println("处理超时啦....");
        e.printStackTrace();
      }
       
      try{
        obj3 = future3.get(3000, TimeUnit.MILLISECONDS); // 任务处理超时时间设为
        }// 1 秒
        catch(Exception e){
          System.out.println("处理超时啦....");
          e.printStackTrace();
        }
       
      try{
       obj2 = future2.get(3000, TimeUnit.MILLISECONDS);}
      catch(Exception e){
        System.out.println("处理超时啦....");
        e.printStackTrace();
      }
      System.out.println("3任务成功返回:" + obj3);
      System.out.println("2任务成功返回:" + obj2);
      System.out.println("1任务成功返回:" + obj);
      exec.shutdown();
    } 
}

以上就是小編為大家帶來的淺談java中異步多線程超時導致的服務異常全部內容了，希望大家多多支持PHP中文網~

更多淺談java中異步多線程超時導致的服務異常相關文章請關注PHP中文網！