线程池-2

子类实现接口：

import java.util.concurrent.Callable;

/*
?* Callable 接口的实现类，作为线程提交任务出现
?* 使用方法返回值
?*
?*/
public class ThreadPoolCallable implements Callable<String> {
?? ?public String call(){
?? ??? ?return "abc";
?? ?}

}

测试类：

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;

/*
?* 实现线程程序的第三个方式，实现Callable接口方式
?* 实现步骤
?* ?? ?工厂类 Executors静态方法newFixedThreadPool方法，创建线程池对象
?* ?? ?线程池对象ExecutorService接口实现类，调用方法submit提交线程任务
?* ?? ?submit(Callable c)
?*/
public class ThreadPoolDemo1 {
?? ?public static void main(String[] args)throws Exception {
?? ??? ?ExecutorService es=Executors.newFixedThreadPool(2);
?? ??? ?//提交线程任务的方法submit方法返回Future接口的实现类
?? ??? ?Future<String> f=es.submit(new ThreadPoolCallable());
?? ??? ?String s=f.get();
?? ??? ?System.out.println(s);
?? ?}
}

（编辑：北几岛）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!