Callable使用

Callable使用实现Callable接口的任务线程能返回执行结果,Callable接口的call()方法允许抛出异常。注意点:Callable接口支持返回执行结果,此时需要调用FutureTask.get()方法实现,此方法会阻塞主线程直到获取‘将来’结果;当不调用此方法时,主线程不会阻塞!packagecom.java.my.callable;importjava.util.co

实现Callable接口的任务线程能返回执行结果,Callable接口的call()方法允许抛出异常。

注意点:

  • Callable接口支持返回执行结果,此时需要调用FutureTask.get()方法实现,此方法会阻塞主线程直到获取‘将来’结果;当不调用此方法时,主线程不会阻塞!
package com.java.my.callable;

import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.FutureTask;

/**
 * @author wanjiadong
 * @description
 * @date Create in 17:16 2018/2/1
 */
public class CallableImpl implements Callable<String> {

    private String str;

    public CallableImpl(String str){
        this.str = str;
    }

    @Override
    public String call() throws Exception {
        Thread.sleep(1000);

        return "call:"+str;
    }

    public static void main(String[] args) throws ExecutionException, InterruptedException {
        CallableImpl callable = new CallableImpl("hello world!");
        FutureTask<String> task = new FutureTask<String>(callable);

        long beginTime = System.currentTimeMillis();
        new Thread(task).start();

        String result = task.get();
        System.out.println("task result = "+result);
        System.out.println("use time="+(System.currentTimeMillis()-beginTime));
    }
}

今天的文章Callable使用分享到此就结束了,感谢您的阅读。

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。
如需转载请保留出处:https://bianchenghao.cn/11438.html

(0)
编程小号编程小号

相关推荐

发表回复

您的电子邮箱地址不会被公开。 必填项已用*标注