Java创建多线程的几种方式

[TOC]

1、继承Thread类，重写run()方法

1//方式1
2package cn.itcats.thread.Test1;
3
4public class Demo1 extends Thread{
5	
6    //重写的是父类Thread的run()
7	public void run() {
8		System.out.println(getName()+"is running...");
9	}
10	
11	
12	public static void main(String[] args) {
13		Demo1 demo1 = new Demo1();
14		Demo1 demo2 = new Demo1();
15		demo1.start();
16		demo2.start();
17	}
18}

2、实现Runnable接口，重写run()

实现Runnable接口只是完成了线程任务的编写
若要启动线程，需要new Thread(Runnable target)，再有thread对象调用start()方法启动线程
此处我们只是重写了Runnable接口的Run()方法，并未重写Thread类的run()，让我们看看Thread类run()的实现
本质上也是调用了我们传进去的Runnale target对象的run()方法

1//Thread类源码中的run()方法
2//target为Thread 成员变量中的 private Runnable target;
3
4 @Override
5    public void run() {
6        if (target != null) {
7            target.run();
8        }
9    }

所以第二种创建线程的实现代码如下：

1package cn.itcats.thread.Test1;
2
3/**
4 * 第二种创建启动线程的方式
5 * 实现Runnale接口
6 * @author fatah
7 */
8public class Demo2 implements Runnable{
9
10    //重写的是Runnable接口的run()
11	public void run() {
12			System.out.println("implements Runnable is running");
13	}
14	
15	public static void main(String[] args) {
16		Thread thread1 = new Thread(new Demo2());
17		Thread thread2 = new Thread(new Demo2());
18		thread1.start();
19		thread2.start();
20	}
21
22}

实现Runnable接口相比第一种继承Thread类的方式，使用了面向接口，将任务与线程进行分离，有利于解耦

3、匿名内部类的方式

适用于创建启动线程次数较少的环境，书写更加简便
具体代码实现：

1package cn.itcats.thread.Test1;
2/**
3 * 创建启动线程的第三种方式————匿名内部类
4 * @author fatah
5 */
6public class Demo3 {
7	public static void main(String[] args) {
8		//方式1：相当于继承了Thread类，作为子类重写run()实现
9		new Thread() {
10			public void run() {
11				System.out.println("匿名内部类创建线程方式1...");
12			};
13		}.start();
14		
15		
16		
17		//方式2:实现Runnable,Runnable作为匿名内部类
18		new Thread(new Runnable() {
19			public void run() {
20				System.out.println("匿名内部类创建线程方式2...");
21			}
22		} ).start();
23	}
24}

4、带返回值的线程(实现implements Callable<返回值类型>)

以上两种方式，都没有返回值且都无法抛出异常。
Callable和Runnbale一样代表着任务，只是Callable接口中不是run()，而是call()方法，但两者相似，即都表示执行任务，call()方法的返回值类型即为Callable接口的泛型
具体代码实现：

1package cn.itcats.thread.Test1;
2
3import java.util.concurrent.Callable;
4import java.util.concurrent.ExecutionException;
5import java.util.concurrent.Future;
6import java.util.concurrent.FutureTask;
7import java.util.concurrent.RunnableFuture;
8
9/**
10 * 方式4:实现Callable<T> 接口
11 * 含返回值且可抛出异常的线程创建启动方式
12 * @author fatah
13 */
14public class Demo5 implements Callable<String>{
15
16	public String call() throws Exception {
17		System.out.println("正在执行新建线程任务");
18		Thread.sleep(2000);
19		return "新建线程睡了2s后返回执行结果";
20	}
21
22	public static void main(String[] args) throws InterruptedException, ExecutionException {
23		Demo5 d = new Demo5();
24		/*	call()只是线程任务,对线程任务进行封装
25			class FutureTask<V> implements RunnableFuture<V>
26			interface RunnableFuture<V> extends Runnable, Future<V>
27		*/
28		FutureTask<String> task = new FutureTask<>(d);
29		Thread t = new Thread(task);
30		t.start();
31		System.out.println("提前完成任务...");
32		//获取任务执行后返回的结果
33		String result = task.get();
34		System.out.println("线程执行结果为"+result);
35	}
36	
37}

5、定时器(java.util.Timer)

关于Timmer的几个构造方法

执行定时器任务使用的是schedule方法：

具体代码实现：

1package cn.itcats.thread.Test1;
2
3import java.util.Timer;
4import java.util.TimerTask;
5
6/**
7 * 方法5：创建启动线程之Timer定时任务
8 * @author fatah
9 */
10public class Demo6 {
11	public static void main(String[] args) {
12		Timer timer = new Timer();
13		timer.schedule(new TimerTask() {
14			@Override
15			public void run() {
16				System.out.println("定时任务延迟0(即立刻执行),每隔1000ms执行一次");
17			}
18		}, 0, 1000);
19	}
20	
21}

我们发现Timer有不可控的缺点，当任务未执行完毕或我们每次想执行不同任务时候，实现起来比较麻烦。这里推荐一个比较优秀的开源作业调度框架“quartz”，在后期我可能会写一篇关于quartz的博文。

6、线程池的实现(java.util.concurrent.Executor接口)

降低了创建线程和销毁线程时间开销和资源浪费
具体代码实现：

1package cn.itcats.thread.Test1;
2
3import java.util.concurrent.Executor;
4import java.util.concurrent.Executors;
5
6public class Demo7 {
7	public static void main(String[] args) {
8		//创建带有5个线程的线程池
9		//返回的实际上是ExecutorService,而ExecutorService是Executor的子接口
10		Executor threadPool = Executors.newFixedThreadPool(5);
11		for(int i = 0 ;i < 10 ; i++) {
12			threadPool.execute(new Runnable() {
13				public void run() {
14					System.out.println(Thread.currentThread().getName()+" is running");
15				}
16			});
17		}
18		
19	}
20}

运行结果：
pool-1-thread-3 is running
pool-1-thread-1 is running
pool-1-thread-4 is running
pool-1-thread-3 is running
pool-1-thread-5 is running
pool-1-thread-2 is running
pool-1-thread-5 is running
pool-1-thread-3 is running
pool-1-thread-1 is running
pool-1-thread-4 is running

运行完毕，但程序并未停止，原因是线程池并未销毁，若想销毁调用threadPool.shutdown(); 注意需要把我上面的
Executor threadPool = Executors.newFixedThreadPool(10); 改为
ExecutorService threadPool = Executors.newFixedThreadPool(10); 否则无shutdown()方法

若创建的是CachedThreadPool则不需要指定线程数量，线程数量多少取决于线程任务，不够用则创建线程，够用则回收。

7、Lambda表达式的实现(parallelStream)

1package cn.itcats.thread.Test1;
2
3import java.util.ArrayList;
4import java.util.Arrays;
5import java.util.List;
6
7/**
8 * 使用Lambda表达式并行计算
9 * parallelStream
10 * @author fatah
11 */
12public class Demo8 {
13	public static void main(String[] args) {
14		List<Integer> list = Arrays.asList(1,2,3,4,5,6);
15		Demo8 demo = new Demo8();
16		int result = demo.add(list);
17		System.out.println("计算后的结果为"+result);
18	}
19	
20	public int add(List<Integer> list) {
21		//若Lambda是串行执行,则应顺序打印
22		list.parallelStream().forEach(System.out :: println);
23		//Lambda有stream和parallelSteam(并行)
24		return list.parallelStream().mapToInt(i -> i).sum();
25	}
26}

运行结果：
4
1
3
5
6
2
计算后的结果为21
事实证明是并行执行

8、Spring实现多线程

(1)新建Maven工程导入spring相关依赖

(2)新建一个java配置类(注意需要开启@EnableAsync注解——支持异步任务)

1package cn.itcats.thread;
2
3import org.springframework.context.annotation.ComponentScan;
4import org.springframework.context.annotation.Configuration;
5import org.springframework.scheduling.annotation.EnableAsync;
6
7@Configuration
8@ComponentScan("cn.itcats.thread")
9@EnableAsync
10public class Config {
11	
12}

(3)书写异步执行的方法类(注意方法上需要有@Async——异步方法调用)

1package cn.itcats.thread;
2
3import org.springframework.scheduling.annotation.Async;
4import org.springframework.stereotype.Service;
5
6@Service
7public class AsyncService {
8	
9	@Async
10	public void Async_A() {
11		System.out.println("Async_A is running");
12	}
13	
14	@Async
15	public void Async_B() {
16		System.out.println("Async_B is running");
17	}
18}

(4)创建运行类

1package cn.itcats.thread;
2
3import org.springframework.context.annotation.AnnotationConfigApplicationContext;
4
5public class Run {
6	public static void main(String[] args) {
7		//构造方法传递Java配置类Config.class
8		AnnotationConfigApplicationContext ac = new AnnotationConfigApplicationContext(Config.class);
9		AsyncService bean = ac.getBean(AsyncService.class);
10		bean.Async_A();
11		bean.Async_B();
12	}
13}

关注公众号:java宝典