每日学习～多线程之线程创建

什么是并发与并行

并行：指两个或多个事件在同一时刻发生（同时发生）；
并发：指两个或多个事件在同一个时间段内发生；

什么是进程与线程

进程：进程是线程的容器，即一个进程中可以开启多个线程；
线程：线程是进程内部的一个独立执行单元，一个进程可以同时并发运行多个线程；
多线程：多个线程并发执行；

线程创建

Java中线程创建有四种方式：

继承Thread 类
实现Runnable 接口
实现Callable 接口
线程池

（1）继承Thread 类

package com.lwt.study.thread.demo1; public class MyThread extends Thread { @Override public void run() { for (int i = 0; i < 10; i++) { System.out.println("mythread 线程正在执行：" + System.currentTimeMillis()); } } }

测试：

public class ThreadCreateDemo { public static void main(String[] args) { //1.创建自定义线程 MyThread thread = new MyThread(); thread.start(); //2.主线程循环打印 for (int i = 0; i < 10; i++) { System.out.println("main 主线程正在执行：" + System.currentTimeMillis()); } } }

运行结果：

（2）实现Runnable 接口

public class MyRunable implements Runnable { @Override public void run() { for (int i = 0; i < 10; i++) { System.out.println("MyRunnable 线程正在执行：" + System.currentTimeMillis()); } } }

测试：

public static void main(String[] args) { //1.创建自定义线程 Thread thread = new Thread(new MyRunable()); thread.start(); //2.主线程循环打印 for (int i = 0; i < 10; i++) { System.out.println("main 主线程正在执行：" + System.currentTimeMillis()); } }

运行结果：

（3）实现Callable 接口

Callable 需要使用FutureTask 类帮助执行，FutureTask 类结构如下：

Future常用方法：

判断任务是否完成：isDone()
能够中断任务：cancel()
能够获取任务执行结果：get()

import java.util.concurrent.Callable; public class MyCallable implements Callable { @Override public String call() throws Exception { for (int i = 0; i < 10; i++) { System.out.println("MyCallable 正在执行：" + System.currentTimeMillis()); } return "MyCallable 执行完毕！"; } }

测试：

public static void main(String[] args) throws ExecutionException, InterruptedException { FutureTask task = new FutureTask(new MyCallable()); Thread thread = new Thread(task); thread.start(); for (int i = 0; i < 10; i++) { System.out.println("main 主线程正在执行：" + System.currentTimeMillis()); } System.out.println(task.get()); }

（4）线程池

线程池线类关系图：

Executor 接口：

声明了execute(Runnable runnable)方法，执行任务代码；

ExecutorService 接口：

继承Executor 接口，声明方法：submit、invokeAll、invokeAny 以及shutDown 等；

AbstractExecutorService 抽象类：

实现ExecutorService 接口，基本实现ExecutorService 中声明的所有方法；

ScheduledExecutorService 接口：

继承ExecutorService 接口，声明定时执行任务方法；

ThreadPoolExecutor 类：

继承类AbstractExecutorService，实现execute、submit、shutdown、shutdownNow方法；

ScheduledThreadPoolExecutor 类：

继承ThreadPoolExecutor 类，实现ScheduledExecutorService 接口并实现其中的方法；

Executors 类：

提供快速创建线程池的方法；

创建测试类：

public class ThreadExecutorDemo { public static void main(String[] args) { //1.使用Executors 创建线程池 ExecutorService executorService = newFixedThreadPool(10); //2.通过线程池执行线程 executorService.execute(new MyRunable()); //3.主线程循环打印 for (int i = 0; i < 10; i++) { System.out.println("main 主线程正在执行：" + System.currentTimeMillis()); } } }

运行结果：