java并发编程学习之FutureTask

BothEyes1993 发布于2019-08-16 18:33 / 2233人阅读

摘要：在并发编程学习之三种线程启动方式中有提过。是否执行结束，包括正常执行结束或异常结束。获取返回值，没有得到返回值前一直阻塞。运行结果如下由于任务被取消，所以抛出异常。注意的是，此时线程还在跑，和返回的是。并不能让任务真正的结束。

FutureTask

在java并发编程学习之三种线程启动方式中有提过。主要的方法如下：

cancel(boolean mayInterruptIfRunning)：取消任务的执行失败，返回false，比如任务已经执行结束，或者已经被取消，或者不能被取消。如果执行成功了，返回ture。mayInterruptIfRunning的作用是是否中断，如果是true则中断，本质还是调用interrupt方法。

isCancelled：判断任务是否被取消，任务结束包括正常执行结束或异常结束，返回true。

isDone：是否执行结束，包括正常执行结束或异常结束。结束返回true。

get：获取返回值，没有得到返回值前一直阻塞。

public class FutureTaskDemo {
    static class Thread1 implements Callable {


        @Override
        public Object call() throws Exception {
            System.out.println("before fun");
            fun();
            System.out.println("after fun");
            return null;
        }

        public void fun() {
            while (true) {

            }
        }
    }

    public static void main(String[] args) {
        Thread1 thread1 = new Thread1();
        FutureTask futureTask = new FutureTask(thread1);
        Thread thread = new Thread(futureTask);
        thread.start();
        try {
            Thread.sleep(1000);
            System.out.println("cancel:" + futureTask.cancel(true));
            Thread.sleep(1000);
            System.out.println("isCancelled:" + futureTask.isCancelled());
            System.out.println("isDone:" + futureTask.isDone());
            System.out.println(futureTask.get());
        } catch (InterruptedException e) {
            System.out.println("InterruptedException");
        } catch (ExecutionException e) {
            System.out.println("ExecutionException");
        } catch (CancellationException e) {
            System.out.println("CancellationException");
        }
    }
}

运行结果如下：

由于任务被取消，所以抛出CancellationException异常。注意的是，此时thread1线程还在跑，isCancelled和isDone返回的是true。cancel并不能让任务真正的结束。

GPU云服务器云服务器学习之substr() 深度学习之概要 webrtc学习之九 linux学习之centos

文章版权归作者所有，未经允许请勿转载,若此文章存在违规行为，您可以联系管理员删除。

转载请注明本文地址：https://www.ucloud.cn/yun/75319.html

java并发编程学习之三种线程启动方式

摘要：类这是方式启动的运行结果如下接口这是方式启动的运行结果如下接口运行结果如下接口和接口的区别可以有返回值。通过包装成，传递给，因为是实现了接口。类Thread public class ThreadDemo extends Thread { public static void main(String[] args) { ThreadDemo thread = ...

enrecul101 2019-08-16 18:27 评论0 收藏0
java并发编程学习之线程池-AbstractExecutorService(二)

摘要：抽象类，实现了的接口。将任务封装成提交任务主要方法在任务是否超时超时时间任务书用于存放结果的，先完成的放前面。 AbstractExecutorService抽象类，实现了ExecutorService的接口。 newTaskFor 将任务封装成FutureTask protected RunnableFuture newTaskFor(Runnable runnable, T va...

Jokcy 2019-08-19 10:16 评论0 收藏0
java并发编程学习之synchronize（一）

摘要：线程安全问题在并发编程学习之基础概念提到，多线程的劣势之一，有个线程安全问题，现在看看下面的例子。那么，该怎么解决呢，很简单，在方法前加个同步锁。运行结果如下有两种情况，是因为看谁先抢占锁，但是输出的算法结果是正确的。线程安全问题在java并发编程学习之基础概念提到，多线程的劣势之一，有个线程安全问题，现在看看下面的例子。 public class NotSafeDemo { ...

Elle 2019-08-16 18:28 评论0 收藏0
java并发编程学习之再谈公平锁和非公平锁

摘要：在并发编程学习之显示锁里有提过公平锁和非公平锁，我们知道他的使用方式，以及非公平锁的性能较高，在源码分析的基础上，我们看看和的区别在什么地方。而非公平锁直接尝试获取锁。在java并发编程学习之显示锁Lock里有提过公平锁和非公平锁，我们知道他的使用方式，以及非公平锁的性能较高，在AQS源码分析的基础上，我们看看NonfairSync和FairSync的区别在什么地方。 lock方法 ...

warkiz 2019-08-19 11:48 评论0 收藏0
java并发编程学习之Volatile

摘要：但是的语义不足以确保递增操作的原子性，在多线程的情况下，线程不一定是安全的。检查某个状态标记，以判断是否退出循环某个方法这边和用普通的变量的区别是，在多线程的情况下，取到后，的值被改变了，判断会不正确。多线程为什么是不安全的这边简单的讲述一下，参考java并发编程学习之synchronize（一）当线程A和线程B同时进入num = num + value; 线程A会把num的值...

thekingisalwaysluc 2019-08-16 18:28 评论0 收藏0