java ExecutorService Callable 任务停止和状态
伊谢尔伦
伊谢尔伦 2017-04-17 13:27:13
0
1
1172

java 并发框架中,使用ExecutorService运行任务,如果是Callable的任务
如何终止耗时比较久的任务(如网络连接),而且Callable任务好像没有Runnable可以查看状态

怎样为每个Callable任务设置超时,超时后停止任务

不像Runnable可以检测到中断信息,还是Callable也可以?

伊谢尔伦
伊谢尔伦

小伙看你根骨奇佳,潜力无限,来学PHP伐。

全部回覆(1)
阿神

// 距提問的時間雖久,但還是把回答寫下來,以供大家參考。

Callable任務設定超時的可行做法如下:

I. 保留提交任務時所回傳的Future物件

Future<Object> future = exec.submit(task);

II. 設定等待任務返回結果的超時時間

int timeout = 5;
future.get(timeout, TimeUnit.SECONDS);

III. 處理超時異常

完整範例程式碼如下:

import java.util.concurrent.*;

public class App {

    public static void main(String[] args) {
        ExecutorService exec = Executors.newSingleThreadExecutor();

        Callable<Object> task = new Callable<Object>() {
            @Override
            public Object call() throws Exception {
                for (int i = 0; i < 10; i++) {
                    // 任务需要运行10秒钟
                    TimeUnit.SECONDS.sleep(1);
                }
                return "task result.";
            }
        };

        // 保留提交任务时所返回的`Future`对象
        Future<Object> future = exec.submit(task);

        try {
            // 设置等待任务返回结果的超时时间
            int timeout = 5;
            Object result = future.get(timeout, TimeUnit.SECONDS);
            System.out.println(result);
        } catch (InterruptedException e) {
            e.printStackTrace();
        } catch (ExecutionException e) {
            e.printStackTrace();
        } catch (TimeoutException e) {
            // 处理超时异常
            System.err.println("超时了");
        }

        exec.shutdown();

    }

}
熱門教學
更多>
最新下載
更多>
網站特效
網站源碼
網站素材
前端模板