超时多线程处理问题

0 0

超时多线程处理问题0

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 TimeOut {
    public static void main(String[] args){
        int timeout = 2; //秒.
        ExecutorService executor = Executors.newSingleThreadExecutor();
        Boolean result = false;
        Future<Boolean> future = executor.submit(new MyJob("请求参数"));// 将任务提交到线程池中
        try {
            result = future.get(timeout*1000, TimeUnit.MILLISECONDS);// 设定在200毫秒的时间内完成
            System.out.println(result);
        } catch (InterruptedException e) {
            System.out.println("线程中断出错。");
            future.cancel(true);// 中断执行此任务的线程
        } catch (ExecutionException e) {
            System.out.println("线程服务出错。");
            future.cancel(true);// 中断执行此任务的线程
        } catch (TimeoutException e) {// 超时异常
            System.out.println("超时。");
            future.cancel(true);// 中断执行此任务的线程
        }finally{
            System.out.println("线程服务关闭。");
            executor.shutdown();
        }
    }

    static class MyJob implements Callable<Boolean> {
        private String t;
        public MyJob(String temp){
            this.t= temp;
        }
        public Boolean call() {
            for(int i=0;i<999999999;i++){
                if(i==999999997){
                    System.out.println(t);
                }
                if (Thread.interrupted()){ //很重要
                    return false;
                }
            }
            System.out.println("继续执行..........");
            return true;
        }
    }
}

不知道有没有在多线程中试过，我用Future试多线程，就会出很多问题，比如：设置的超时时间是所有任务要执行的时间，不是每个线程的超时时间！求解答~，怎么样处理才可以引入多线程来处理

多线程

2014年9月18日 09:49

ljz0898
3
0 0 4

1个答案按时间排序按投票排序

0 0

ExecutorService executor = Executors.newSingleThreadExecutor();
这个是创建一个只有一个线程的线程池，意味着从这获取线程干活，那么只能等上一个干完了再开始下一个。

多线程调用，当然是多处并发调用了，那么自然就构成并发任务了。可以简单的在主线程用for循环提交多个任务，自然就是多个线程并发了，因为提交任务很快，而每个提交的任务需要点时间才能完成。

2014年9月18日 17:29