一. 继承Thread类

继承Thread类创建线程的步骤:

• 创建一个自定义类继承Thread类,重写run()方法,将所要单独线程运行写入run()方法中;
• 创建Thread类的子类的对象;
• 调用该对象的start()方法,该start()方法表示开启线程,然后调用执行run方法;

 	@Testpublic void test() {Thread.currentThread().setName("主进程");System.out.println("当前线程为:" + Thread.currentThread().getName());//创建一个新线程ThreadDemo thread1 = new ThreadDemo();//为线程设置名称thread1.setName("次线程");//开启线程thread1.start();}class ThreadDemo extends Thread {@Overridepublic void run() {System.out.println("当前线程为:" + Thread.currentThread().getName());}}

二. 继承Runnable接口

实现Runnable接口创建线程的步骤为:

• 创建一个类并实现Runnable接口(可以使用Lambda表达式)
• 重写run()方法,将所要单独线程的代码写入run()方法中
• 创建该类对象,将该对象作为Thread类的构造器参数传入
• 使用构造器创建对象调用start()方法(运行该线程)

@Testpublic void test() {Thread.currentThread().setName("主进程");System.out.println("当前线程为:" + Thread.currentThread().getName());//创建线程Thread thread = new Thread(() -> {System.out.println("当前线程为:" + Thread.currentThread().getName());});thread.setName("次线程");thread.start();Thread thread1 = new Thread(new ThreadDemo());thread1.setName("次次线程");thread1.start();}class ThreadDemo implements Runnable {@Overridepublic void run() {System.out.println("当前线程为:" + Thread.currentThread().getName());}}

三. 实现Callable接口与创建Future接口实现类对象

实现Callable接口并实现Callable接口

• 创建一个类并实现Callable接口(可以使用Lambda表达式)
• 重写call()方法,将所要单独线程执行的代码写进call方法中,需要注意的是call()方法是有返回值的,并且可以抛出异常
• 如果想要获取运行该线程后的返回值,需要创建Futrue接口的实现类的对象,也就是FutureTask的对象,通过调用该对象的get()方法得到call()方法的返回值
  
• 使用FutureTask的带参构造器创建对象,并传入实现了Callable接口的类的对象(可以使用Lambda表达式)
• 使用Thread类的带参构造器创建对象,将FutureTask类的对象作为参数传入,然后调用Thread类的对象的start()方法运行该线程

	@Testpublic void test5() throws ExecutionException, InterruptedException {Thread.currentThread().setName("主进程");System.out.println("当前线程为:" + Thread.currentThread().getName());//创建FutureTaskFutureTask<String> futureTask = new FutureTask<>(() -> {System.out.println("当前线程为:" + Thread.currentThread().getName());return "二级线程";});//创建线程Thread thread = new Thread(futureTask, "次线程");thread.start();System.out.println("当前返回值为:" + futureTask.get());//不使用Lambda表达式FutureTask<String> stringFutureTask = new FutureTask<String>(new ThreadDemo());new Thread(stringFutureTask, "次线程二").start();System.out.println("当前返回值为:" +stringFutureTask.get());}class ThreadDemo implements Callable {@Overridepublic Object call() throws Exception {System.out.println("当前线程为:" + Thread.currentThread().getName());return "二级线程";}}

四. 使用线程池创建

使用线程池创建线程的步骤

• 使用Executors类中的newFixedThreadPool(int num)方法创建一个线程数量为num的线程池
• 使用线程池中的execute()方法执行由实现Runnable接口创建的线程,使用submit()方法执行由实现Callable接口创建的线程
• 调用线程池中的shutdown()方法关闭线程池(只是关闭了获取线程,线程池并未立即死亡,会在执行完被调用的线程后死亡)

 	//实现Runnable接口class ThreadDemo6 implements Runnable {@Overridepublic void run() {try {Thread.sleep(1000);} catch (InterruptedException e) {e.printStackTrace();}System.out.println("ThreadDemo6当前线程为:" + Thread.currentThread().getName());}}//实现Runnable接口class ThreadDemo7 implements Runnable {@Overridepublic void run() {try {Thread.sleep(1000);} catch (InterruptedException e) {e.printStackTrace();}System.out.println("ThreadDemo7当前线程为:" + Thread.currentThread().getName());}}class ThreadDemo8 implements Callable<String> {@Overridepublic String call() {try {Thread.sleep(1000);} catch (InterruptedException e) {e.printStackTrace();}System.out.println("ThreadDemo8当前线程为:" + Thread.currentThread().getName());return "ThreadDemo8返回的结果:" + Thread.currentThread().getName();}}@Testpublic void test6() throws ExecutionException, InterruptedException {Thread.currentThread().setName("主线程");System.out.println("当前线程为:" + Thread.currentThread().getName());//通过线程池工厂创建线程数量为2的线程池ExecutorService executorService = Executors.newFixedThreadPool(2);executorService.execute(new ThreadDemo6());executorService.execute(new ThreadDemo7());//submit()用于实现Callable接口创建的线程Future<String> task = executorService.submit(new ThreadDemo8());//获取call方法的返回值String result = task.get();System.out.println(result);//关闭线程池executorService.shutdown();}