重庆分公司,新征程启航
为企业提供网站建设、域名注册、服务器等服务
小编给大家分享一下java如何实现Callable接口创建线程类,相信大部分人都还不怎么了解,因此分享这篇文章给大家参考一下,希望大家阅读完这篇文章后大有收获,下面让我们一起去了解一下吧!
从网站建设到定制行业解决方案,为提供成都做网站、成都网站制作服务体系,各种行业企业客户提供网站建设解决方案,助力业务快速发展。创新互联建站将不断加快创新步伐,提供优质的建站服务。
从 Java5 开始就提供了 Callable 接口,该接口是 Runnable 接口的增强版,Callable 接口提供一个 call() 方法作为线程执行体,call()方法可以有返回值,call() 方法可以声明抛出异常。
boolean cancel(boolean may)
试图取消该 Future 里关联的 Callable 任务。
V get()
返回 Call 任务里 call() 方法的返回值。调用该方法会照成线程阻塞,必须等待子线程结束后才会得到返回值。
V get(long timeout,TimeUnit unit)
返回 Call 任务里 call() 方法的返回值。该方法让程序最多阻塞 timeout 和 unit 指定的时间,如果经过指定的时间,如果经过指定的时间依然没有返回值,将会抛出 TimeoutException 异常。
boolean isCancelled()
如果在 Callable 任务正常完成前被取消,则返回 true。
boolean isDone()
如果 Callable 任务已完成,则返回 true。
Runnable的实现步骤:
创建 Callable 接口的实现类,并实现 call() 方法,该 call() 方法作为线程的执行体,call() 方法有返回值。
使用 FutrueTask 类包装 Callable 对象。
使用 FutrueTask 对象作为Thread 对象的 target 创建并启动新线程。
启用 FutrueTask 对象的 get() 方法来获得子线程的返回值。
public class CallableDemo implements Callable {
public static void main(String args[]) {
FutureTask futureTask = new FutureTask(new CallableDemo());
new Thread(futureTask).start();
try {
System.out.println("子线程返回值:" + futureTask.get());
} catch (InterruptedException e) {
e.printStackTrace();
} catch (ExecutionException e) {
e.printStackTrace();
}
if (futureTask.isDone()) {
System.out.println("线程结束");
}
}
@Override
public Integer call() throws Exception {
System.out.println("线程开始");
int ss = 0;
for (int i = 0; i < 20; i++) {
ss += i;
}
return ss;
}
}
以上是“java如何实现Callable接口创建线程类”这篇文章的所有内容,感谢各位的阅读!相信大家都有了一定的了解,希望分享的内容对大家有所帮助,如果还想学习更多知识,欢迎关注创新互联行业资讯频道!