1、Thread
继承Thread类,并重写run方法
classThreadDemo1extendsThread{@Overridepublicvoidrun(){log.info("{}",Thread.currentThread().getName());}}
线程启动方式
ThreadDemo1t1=newThreadDemo1();t1.setName("t1");t1.start();
简便写法
Threadt1=newThread(){@Overridepublicvoidrun(){log.info("{}",Thread.currentThread().getName());}};t1.setName("t1");t1.start();
2、Runnable和Thread
Thread类的构造函数支持传入Runnable的实现类
publicThread(Runnabletarget){init(null,target,"Thread-"+nextThreadNum(),0);}Thread(Runnabletarget,AccessControlContextacc){init(null,target,"Thread-"+nextThreadNum(),0,acc,false);}
Runnable是一个函数式接口(FunctionalInterface)
@FunctionalInterfacepublicinterfaceRunnable{//没有返回值publicabstractvoidrun();}
因此需要创建类实现Runnable接口,重写run方法
classThreadDemo2implementsRunnable{@Overridepublicvoidrun(){log.info("{}",Thread.currentThread().getName());}}
简便写法
Threadt2=newThread(()->log.info("{}",Thread.currentThread().getName()),"t2");t2.start();
3、Callable和Thread
Callable和Runnable一样,也是一个函数式接口,二者的区别非常明显,Runnable中run方法没有返回值,Callable中的run方法有返回值(可以通过泛型约束返回值类型)。因此在需要获取线程执行的返回值时,可以使用Callable。
@FunctionalInterfacepublicinterfaceCallable<V>{//带返回值Vcall()throwsException;}
在Thread的构造函数中,并没有看到Callable,只有Runnable
此时需要一个可以提交Callable给Thread的类,这类就是FutureTask;FutureTask实现类Runnable接口。
并且FutureTask提供了传入Callable的构造函数
publicFutureTask(Callable<V>callable){if(callable==null)thrownewNullPointerException();this.callable=callable;this.state=NEW;//ensurevisibilityofcallable}
因此可以通过FutureTask传入Callable实现,再将FutureTask传给Thread即可
ThreadDemo3implementsCallable<Integer>{@OverridepublicIntegercall()throwsException{log.info("{}",Thread.currentThread().getName());return1998;}}
ThreadDemo1t1=newThreadDemo1();t1.setName("t1");t1.start();0
简便写法
ThreadDemo1t1=newThreadDemo1();t1.setName("t1");t1.start();1
4、三者对比
创建线程的方式有三种,Thread、Runnable+Thread、Callable+FutureTask+Thread;这三者如何选择呢?
首先在实际的开发过程中,我们不会直接创建线程,因为频繁创建和销毁线程开销比较大,此外不利于管理和释放,因此项目中都是通过设计线程池来管理线程资源
Thread、Runnable+Thread相比,Runnable+Thread将线程的创建和任务模块解耦了,代码设计更加灵活,此外更加利于任务的提交,更方便和线程池结合使用
Callable+FutureTask+Thread适用于需要获取线程返回结果的场景
5、注意项
文中多次使用thread.start();需要注意的是,调用线程的start()方法表示启动线程,但是线程是否执行并不确定,这需要操作系统调度,线程分配到CPU执行时间片才能执行。多核CPU下多个线程同时启动,线程之间交替执行,执行顺序是不确定的。