8种创建Java线程的方式,你知道几个?

作者:唐彤
简介创建线程 , 是多线程编程中最基本的操作 , 彤哥总结了一下 , 大概有8种创建线程的方式 , 你知道吗?

8种创建Java线程的方式,你知道几个?

文章插图
 
1.继承Thread类并重写run()方法public class CreatingThread01 extends Thread { @Override public void run() { System.out.println(getName() + " is running"); } public static void main(String[] args) { new CreatingThread01().start(); new CreatingThread01().start(); new CreatingThread01().start(); new CreatingThread01().start(); }}继承Thread类并重写run()方法 , 这种方式的弊端是一个类只能继承一个父类 , 如果这个类本身已经继承了其它类 , 就不能使用这种方式了 。
2.实现Runnable接口public class CreatingThread02 implements Runnable { @Override public void run() { System.out.println(Thread.currentThread().getName() + " is running"); } public static void main(String[] args) { new Thread(new CreatingThread02()).start(); new Thread(new CreatingThread02()).start(); new Thread(new CreatingThread02()).start(); new Thread(new CreatingThread02()).start(); }}实现Runnable接口 , 这种方式的好处是一个类可以实现多个接口 , 不影响其继承体系 。
3.匿名内部类public class CreatingThread03 { public static void main(String[] args) { // Thread匿名类 , 重写Thread的run()方法 new Thread() { @Override public void run() { System.out.println(getName() + " is running"); } }.start(); // Runnable匿名类 , 实现其run()方法 new Thread(new Runnable() { @Override public void run() { System.out.println(Thread.currentThread().getName() + " is running"); } }).start(); // 同上 , 使用lambda表达式函数式编程 new Thread(()->{ System.out.println(Thread.currentThread().getName() + " is running"); }).start(); }}使用匿名类的方式 , 一是重写Thread的run()方法 , 二是传入Runnable的匿名类 , 三是使用lambda方式 , 现在一般使用第三种(JAVA8+) , 简单快捷 。
4.实现Callabe接口public class CreatingThread04 implements Callable<Long> { @Override public Long call() throws Exception { Thread.sleep(2000); System.out.println(Thread.currentThread().getId() + " is running"); return Thread.currentThread().getId(); } public static void main(String[] args) throws ExecutionException, InterruptedException { FutureTask<Long> task = new FutureTask<>(new CreatingThread04()); new Thread(task).start(); System.out.println("等待完成任务"); Long result = task.get(); System.out.println("任务结果:" + result); }}实现Callabe接口 , 可以获取线程执行的结果 , FutureTask实际上实现了Runnable接口 。
5.定时器(java.util.Timer)public class CreatingThread05 { public static void main(String[] args) { Timer timer = new Timer(); // 每隔1秒执行一次 timer.schedule(new TimerTask() { @Override public void run() { System.out.println(Thread.currentThread().getName() + " is running"); } }, 0 , 1000); }}使用定时器java.util.Timer可以快速地实现定时任务 , TimerTask实际上实现了Runnable接口 。
6.线程池public class CreatingThread06 { public static void main(String[] args) { ExecutorService threadPool = Executors.newFixedThreadPool(5); for (int i = 0; i < 100; i++) { threadPool.execute(()-> System.out.println(Thread.currentThread().getName() + " is running")); } }}使用线程池的方式 , 可以复用线程 , 节约系统资源 。
7.并行计算(Java8+)public class CreatingThread07 { public static void main(String[] args) { List<Integer> list = Arrays.asList(1, 2, 3, 4, 5); // 串行 , 打印结果为12345 list.stream().forEach(System.out::print); System.out.println(); // 并行 , 打印结果随机 , 比如35214 list.parallelStream().forEach(System.out::print); }}使用并行计算的方式 , 可以提高程序运行的效率 , 多线程并行执行 。
8.Spring异步方法【8种创建Java线程的方式,你知道几个?】首先 , springboot启动类加上 @EnableAsync注解(@EnableAsync是spring支持的 , 这里方便举例使用springboot) 。
@SpringBootApplication@EnableAsyncpublic class Application { public static void main(String[] args) { SpringApplication.run(Application.class, args); }}其次 , 方法加上 @Async注解 。
@Servicepublic class CreatingThread08Service { @Async public void call() { System.out.println(Thread.currentThread().getName() + " is running"); }}然后 , 测试用例直接跟使用一般的Service方法一模一样 。


推荐阅读