public class ThreadForever {
 
    @Test
    public void demo() {
        ExecutorService service = Executors.newFixedThreadPool(3);
 
        // 如果是仅仅一个线程，就用Future 就够了，不需要CompletionService
        CompletionService<Boolean> completion = new ExecutorCompletionService<Boolean>(service);
 
        completion.submit(new Work());
 
        // 此段可以启用一个新的线程单独执行，防止阻塞主线程
        while (true) {
            try {
                System.out.println("Success：" + completion.take().get());
                break;
            }
            catch (Exception e) {
                // 运行过程中出现了异常
                e.printStackTrace();
                completion.submit(new Work());
            }
        }
 
        service.shutdown();
    }
 
    class Work implements Callable<Boolean> {
 
        @Override
        public Boolean call() throws Exception {
            for (int i = 0; i < 5; i++) {
                System.out.println(Thread.currentThread().getName() + "->" + i);
                 
//                try {
//                    Thread.sleep(100);
//                } catch (InterruptedException e) {
//                    e.printStackTrace();
//                }
 
                // 抛出异常，使线程中断
                if (i % 3 == 1) {
                    @SuppressWarnings("unused")
                    int e = 1 / 0;
                }
            }
 
            return true;
        }
    }
}

回复 "java 线程意外结束后自动生成新线程"

这儿你可以回复上面这条便签

作者你的名字是？

标题给你的便签一个标题。

语言你的便签是以

你的便签在这儿输入便签内容

public class ThreadForever {
 
    @Test
    public void demo() {
        ExecutorService service = Executors.newFixedThreadPool(3);
 
        // 如果是仅仅一个线程，就用Future 就够了，不需要CompletionService
        CompletionService<Boolean> completion = new ExecutorCompletionService<Boolean>(service);
 
        completion.submit(new Work());
 
        // 此段可以启用一个新的线程单独执行，防止阻塞主线程
        while (true) {
            try {
                System.out.println("Success：" + completion.take().get());
                break;
            }
            catch (Exception e) {
                // 运行过程中出现了异常
                e.printStackTrace();
                completion.submit(new Work());
            }
        }
 
        service.shutdown();
    }
 
    class Work implements Callable<Boolean> {
 
        @Override
        public Boolean call() throws Exception {
            for (int i = 0; i < 5; i++) {
                System.out.println(Thread.currentThread().getName() + "->" + i);
                 
//                try {
//                    Thread.sleep(100);
//                } catch (InterruptedException e) {
//                    e.printStackTrace();
//                }
 
                // 抛出异常，使线程中断
                if (i % 3 == 1) {
                    @SuppressWarnings("unused")
                    int e = 1 / 0;
                }
            }
 
            return true;
        }
    }
}

创建短链接创建一个较短的URL，连接到这个便签

私人私人便签不会显示在最近列表中

保存期限我们应该什么时候删除这张便签？

防滥用键入这些字符

Code666 (代码贴、代码片段)

[Java] java 线程意外结束后自动生成新线程 →→→→→进入此内容的聊天室

回复 "java 线程意外结束后自动生成新线程"