简介

创建线程，是多线程编程中最基本的操作

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.匿名内部类 lambda实现

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
    
      {    @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
     
       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
    
      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异步方法

首先，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方法一模一样。

@RunWith(SpringRunner.class)@SpringBootTest(classes = Application.class)public class CreatingThread08Test {    @Autowired    private CreatingThread08Service creatingThread08Service;    @Test    public void test() {        creatingThread08Service.call();        creatingThread08Service.call();        creatingThread08Service.call();        creatingThread08Service.call();    }}

运行结果如下：

task-3 is runningtask-2 is runningtask-1 is runningtask-4 is running

可以看到每次执行方法时使用的线程都不一样。 使用Spring异步方法的方式，可以说是相当地方便，适用于前后逻辑不相关联的适合用异步调用的一些方法，比如发送短信的功能。

总结

（1）继承Thread类并重写run()方法；