知识大全 Java5 并发线程学习

Posted 2022-07-14 知

篇首语：水滴集多成大海，读书集多成学问。本文由小常识网(cha138.com)小编为大家整理，主要介绍了知识大全 Java5 并发线程学习相关的知识，希望对你有一定的参考价值。

Java5 并发线程学习 以下文字资料是由(全榜网网www.cha138.com)小编为大家搜集整理后发布的内容，让我们赶快一起来看一下吧！

　　在Java 之后并发线程这块发生了根本的变化最重要的莫过于新的启动调度管理线程的一大堆API了在Java 以后通过Executor来启动线程比用Thread的start（）更好在新特征中可以很容易控制线程的启动执行和关闭过程还可以很容易使用线程池的特性

　　一创建任务

　　任务就是一个实现了Runnable接口的类

　　创建的时候实run方法即可

　　二执行任务

　　通过ncurrent ExecutorService接口对象来执行任务该接口对象通过工具类ncurrent Executors的静态方法来创建

　　Executors此包中所定义的 Executor ExecutorService ScheduledExecutorService ThreadFactory 和 Callable 类的工厂和实用方法

　　ExecutorService提供了管理终止的方法以及可为跟踪一个或多个异步任务执行状况而生成 Future 的方法可以关闭 ExecutorService 这将导致其停止接受新任务关闭后执行程序将最后终止这时没有任务在执行也没有任务在等待执行并且无法提交新任务

　　executorService execute（new TestRunnable（））

　　创建ExecutorService

　　通过工具类ncurrent Executors的静态方法来创建

　　Executors此包中所定义的 Executor ExecutorService ScheduledExecutorService ThreadFactory 和 Callable 类的工厂和实用方法

　　比如创建一个ExecutorService的实例 ExecutorService实际上是一个线程池的管理工具

　　ExecutorService executorService = Executors newCachedThreadPool（）

　　ExecutorService executorService = Executors newFixedThreadPool（）

　　ExecutorService executorService = Executors newSingleThreadExecutor（）

　　将任务添加到线程去执行

　　当将一个任务添加到线程池中的时候线程池会为每个任务创建一个线程该线程会在之后的某个时刻自动执行

　　三关闭执行服务对象

　　executorService shutdown（）

　　四综合实例

　　 package concurrent; import ncurrent ExecutorService; import ncurrent Executors; /** * Created by IntelliJ IDEA * * @author leizhimin : : */ public class TestCachedThreadPool public static void main(String[] args) // ExecutorService executorService = Executors newCachedThreadPool(); ExecutorService executorService = Executors newFixedThreadPool( ); // ExecutorService executorService = Executors newSingleThreadExecutor(); for (int i = ; i < ; i++) executorService execute(new TestRunnable()); System out println( ************* a + i + ************* ); executorService shutdown(); class TestRunnable implements Runnable public void run() System out println(Thread currentThread() getName() + 线程被调用了 ); while (true) try Thread sleep( ); System out println(Thread currentThread() getName()); catch (InterruptedException e) e printStackTrace();

　　运行结果

　　 ************* a ************* ************* a ************* pool thread 线程被调用了 ************* a ************* pool thread 线程被调用了 pool thread 线程被调用了 ************* a ************* ************* a ************* pool thread 线程被调用了 pool thread 线程被调用了 pool thread pool thread pool thread pool thread pool thread pool thread pool thread pool thread pool thread pool thread

　　五获取任务的执行的返回值

　　在Java 之后任务分两类一类是实现了Runnable接口的类一类是实现了Callable接口的类两者都可以被ExecutorService执行但是Runnable任务没有返回值而Callable任务有返回值并且Callable的call（）方法只能通过ExecutorService的submit（Callable<T> task）方法来执行并且返回一个 <T> Future<T> 是表示任务等待完成的 Future

　　public interface Callable<V>返回结果并且可能抛出异常的任务实现者定义了一个不带任何参数的叫做 call 的方法

　　Callable 接口类似于 Runnable 两者都是为那些其实例可能被另一个线程执行的类设计的但是 Runnable 不会返回结果并且无法抛出经过检查的异常

　　Executors 类包含一些从其他普通形式转换成 Callable 类的实用方法

　　Callable中的call（）方法类似Runnable的run（）方法就是前者有返回值后者没有

　　当将一个Callable的对象传递给ExecutorService的submit方法则该call方法自动在一个线程上执行并且会返回执行结果Future对象

　　同样将Runnable的对象传递给ExecutorService的submit方法则该run方法自动在一个线程上执行并且会返回执行结果Future对象但是在该Future对象上调用get方法将返回null

　　遗憾的是在Java API文档中这块介绍的很糊涂估计是翻译人员还没搞清楚的缘故吧或者说是注释不到位下面看个例子

　　 import java util ArrayList; import java util List; import ncurrent *; /** * Callable接口测试 * * @author leizhimin : : */ public class CallableDemo public static void main(String[] args) ExecutorService executorService = Executors newCachedThreadPool(); List<Future<String>> resultList = new ArrayList<Future<String>>(); //创建个任务并执行 for (int i = ; i < ; i++) //使用ExecutorService执行Callable类型的任务并将结果保存在future变量中 Future<String> future = executorService submit(new TaskWithResult(i)); //将任务执行结果存储到List中 resultList add(future); //遍历任务的结果 for (Future<String> fs : resultList) try System out println(fs get()); //打印各个线程（任务）执行的结果 catch (InterruptedException e) e printStackTrace(); catch (ExecutionException e) e printStackTrace(); finally //启动一次顺序关闭执行以前提交的任务但不接受新任务如果已经关闭则调用没有其他作用 executorService shutdown(); class TaskWithResult implements Callable<String> private int id; public TaskWithResult(int id) this id = id; /** * 任务的具体过程一旦任务传给ExecutorService的submit方法则该方法自动在一个线程上执行 * * @return * @throws Exception */ public String call() throws Exception System out println( call()方法被自动调用干活！！！ + Thread currentThread() getName()); //一个模拟耗时的操作 for (int i = ; i > ; i ) ; return call()方法被自动调用任务的结果是 + id + + Thread currentThread() getName();

　　运行结果

cha138/Article/program/Java/gj/201311/27417