多线程知识点一

淡淡的烟草味﹌ 2022-02-01 03:39 290阅读 0赞

**1、创建线程的2种方式:**

一种是直接继承Thread，另外一种就是实现Runnable接口。

这2种方式都有一个缺陷就是：在执行完任务之后无法获取执行结果。如果需要获取执行结果，就必须通过共享变量或者使用线程通信的方式来达到效果，这样使用起来就比较麻烦。

**2、Callable和Future，通过它们可以在任务执行完毕之后得到任务执行结果。**

**2.1、Callable**

Callable和Runnable差不多，两者都是为那些可能被另一个线程执行的类而设计的，最主要的差别在于Runnable不会返回线程运算结果，Callable可以（假如线程需要返回运行结果）

**2.2、Future**

Future是一个接口表示异步计算的结果，它提供了检查计算是否完成的方法，以等待计算的完成，并获取计算的结果。Future提供了get()、cancel()、isCancel()、isDone()四种方法，表示Future有三种功能：

1、判断任务是否完成

2、中断任务

3、获取任务执行结果

**2.3、FutureTask**

FutureTask是Future的实现类，它提供了对Future的基本实现。可使用FutureTask包装Callable或Runnable对象，因为FutureTask实现了Runnable，所以也可以将FutureTask提交给Executor。

使用方法：

Callable、Future、FutureTask一般都是和线程池配合使用的，因为线程池ThreadPoolExecutor的父类AbstractExecutorService提供了三种submit方法：

1、public Future<?> subit(Runnable task)\{...\}

2、public <T> Future<T> submit<Runnable task, T result>\{...\}

3、public <T> Future<T> submit<Callable<T> task>\{...\}

第1个和第3个比较有用

Callable+Future使用示例

public static class CallableThread implements Callable<String>

public String call() throws Exception

Thread.sleep(10000);

return "123";

public static void main(String\[\] args) throws Exception

ExecutorService es = Executors.newCachedThreadPool();

CallableThread ct = new CallableThread();

Future<String> f = es.submit(ct);

System.out.println("主线程等待5秒, 当前时间为" + System.currentTimeMillis());

String str = f.get();

System.out.println("Future已拿到数据, str = " + str + ", 当前时间为" + System.currentTimeMillis());

运行结果为：

进入CallableThread的call()方法, 开始睡觉, 睡觉时间为1444654421368

主线程等待5秒, 当前时间为1444654426369

Future已拿到数据, str = 123, 当前时间为1444654431369

看到任意一个利用Callable接口submit上去的任务，只要有一个Future接受它，Future便可以在程序任何地点尝试去获取这条线程返回出去的数据，时间可以比对一下，正好10000ms，即10s

Callable+FutureTask使用示例

有兴趣的可以看下源码，其实使用Callable+Future的方式，es.submit(ct)方法返回的Future，底层实现new出来的是一个FutureTask。那么，我们看一下Callable+FutureTask的方式：

public static class CallableThread implements Callable<String>

public String call() throws Exception

System.out.println("进入CallableThread的call()方法, 开始睡觉, 睡觉时间为" + System.currentTimeMillis());

Thread.sleep(10000);

return "123";

public static void main(String\[\] args) throws Exception

ExecutorService es = Executors.newCachedThreadPool();

CallableThread ct = new CallableThread();

FutureTask<String> f = new FutureTask<String>(ct);

es.submit(f);

es.shutdown();

Thread.sleep(5000);

System.out.println("主线程等待5秒, 当前时间为" + System.currentTimeMillis());

String str = f.get();

System.out.println("Future已拿到数据, str = " + str + ", 当前时间为" + System.currentTimeMillis());

看下运行结果：

进入CallableThread的call()方法, 开始睡觉, 睡觉时间为1444655049199

主线程等待5秒, 当前时间为1444655054200

Future已拿到数据, str = 123, 当前时间为1444655059200

上面演示了两个例子，其实反映的是现实中一种情况，把上面的例子稍微扩展一下就是：

有一个method()方法，方法中执行方法A返回一个数据要10秒钟，A方法后面的代码一共要执行20秒钟，但是这20秒的代码中有10秒的方法并不依赖方法A的执行结果，有10秒钟的代码依赖方法A的执行结果。此时若采用同步的方式，那么势必要先等待10秒钟，等待方法A执行完毕，返回数据，再执行后面20秒的代码。

不得不说这是一种低效率的做法。有了Callable、Future和FutureTask，那么：

1、先把A方法的内容放到Callable实现类的call()方法中

2、method()方法中，Callable实现类传入Executor的submit方法中

3、执行后面方法中10秒不依赖方法A运行结果的代码

4、获取方法A的运行结果，执行后面方法中10秒依赖方法A运行结果的代码

这样代码执行效率一下子就提高了，程序不必卡在A方法处。

**2.4、executorService提交任务submit和execute方法的区别**

1、接收的参数不一样（execute的参数是Runnable，submit的参数是Callable）

2、submit有返回值，而execute没有

3、submit方便Exception处理

意思就是如果你在你的task里会抛出checked或者unchecked exception，而你又希望外面的调用者能够感知这些exception并做出及时的处理，那么就需要用到submit，通过捕获Future.get抛出的异常。

例如: