一、多线程

1.1 多线程概述

1.1.1 并发与并行

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

并发：在操作系统中，安装了多个程序，并发指的是在一段时间内宏观上有多个程序同时运行，这在单 CPU 系统中，每一时刻只能有一道程序执行，即微观上这些程序是分时的交替运行，只不过是给人的感觉是同时运行，那是因为分时交替运行的时间是非常短的。

并行：而在多个 CPU 系统中，则这些可以并发执行的程序便可以分配到多个处理器上（CPU），实现多任务并行执行，即利用每个处理器来处理一个可以并发执行的程序，这样多个程序便可以同时执行。目前电脑市场上说的多核 CPU，便是多核处理器，核越多，并行处理的程序越多，能大大的提高电脑运行的效率。

1.1.2 线程与进程

进程：是指一个内存中运行的应用程序，每个进程都有一个独立的内存空间，一个应用程序可以同时运行多个进程；进程也是程序的一次执行过程，是资源分配的基本单位（分配内存、硬盘、摄像头等资源）；系统运行一个程序即是一个进程从创建、运行到消亡的过程。
线程：线程是进程中的一个执行单元，负责当前进程中程序的执行，一个进程中至少有一个线程（主线程），线程是CPU进行调度或运行的基本单位。一个进程中是可以有多个线程的，这个应用程序也可以称之为多线程程序。
- 多线程的好处：
  - CPU的利用率比较高
  - 用户体验好
  - 简化开发

1.2 线程的创建与状态

1.2.1 Thread类

构造方法：

public Thread()：分配一个新的线程对象。
public Thread(String name)：分配一个指定名字的新的线程对象。
public Thread(Runnable target)：分配一个带有指定目标新的线程对象。
public Thread(Runnable target,String name)：分配一个带有指定目标新的线程对象并指定名字。

常用方法：

public String getName()：获取当前线程名称。
public void start()：导致此线程开始执行（线程的运行）， Java虚拟机调用此线程的run方法。
public void run()：此线程要执行的任务在此处定义代码（方法的调用）。
public static void sleep(long millis)：使当前正在执行的线程以指定的毫秒数暂停（暂时停止执行）。
public static Thread currentThread()：返回对当前正在执行的线程对象的引用。

1.2.2 继承Thread方式创建线程

Java使用java.lang.Thread类代表线程，所有的线程对象都必须是Thread类或其子类的实例。每个线程的作用是完成一定的任务，实际上就是执行一段程序流即一段顺序执行的代码。Java使用线程执行体来代表这段程序流。Java中通过继承Thread类来创建并启动多线程的步骤如下：

定义Thread类的子类，并重写该类的run()方法，该run()方法的方法体就代表了线程需要完成的任务，因此把run()方法称为线程执行体。
创建Thread子类的实例，即创建了线程对象
调用线程对象的start()方法来启动该线程

测试类：

public class Demo01 {
	public static void main(String[] args) {
		//创建自定义线程对象
		MyThread mt = new MyThread("新的线程！");
		//开启新线程
		mt.start();
		//在主方法中执行for循环
		for (int i = 0; i < 10; i++) {
			System.out.println("main线程！"+i);
		}
	}
}

自定义线程类：

public class MyThread extends Thread {
	//定义指定线程名称的构造方法
	public MyThread(String name) {
		//调用父类的String参数的构造方法，指定线程的名称
		super(name);
	}
	/**
	 * 重写run方法，完成该线程执行的逻辑
	 */
	@Override
	public void run() {
		for (int i = 0; i < 10; i++) {
			System.out.println(getName()+"：正在执行！"+i);
		}
	}
}

1.2.3 实现接口方式创建线程

实现java.lang.Runnable，重写run()方法来创建线程，步骤如下：

定义Runnable接口的实现类，并重写该接口的run()方法，该run()方法的方法体同样是该线程的线程执行体。
创建Runnable实现类的实例，并以此实例作为Thread的target来创建Thread对象，该Thread对象才是真正的线程对象。
调用线程对象的start()方法来启动线程。

public class MyRunnable implements Runnable{
	@Override
	public void run() {
		for (int i = 0; i < 20; i++) {
		System.out.println(Thread.currentThread().getName()+" "+i);
		}
	}
}

public class Demo {
	public static void main(String[] args) {
		//创建自定义类对象 线程任务对象
		MyRunnable mr = new MyRunnable();
		//创建线程对象
		Thread t = new Thread(mr, "小强");
		t.start();
		for (int i = 0; i < 20; i++) {
			System.out.println("旺财 " + i);
		}
	}
}

Runnable对象仅仅作为Thread对象的target，Runnable实现类里包含的run()方法仅作为线程执行体。而实际的线程对象依然是Thread实例，只是该Thread线程负责执行其target的run()方法。

1.2.4 Thread和Runnable创建线程的区别

Thread类
- 通过继承创建线程，创建方式简单
- 单继承，有一定的局限性
Runnable接口
- 通过实现接口创建线程
- 多实现，可以避免java中的单继承的局限性，灵活
- 适合多个相同的程序代码的线程去共享同一个资源
- 增加程序的健壮性，实现解耦操作，代码可以被多个线程共享，代码和线程独立
- 线程池只能放入实现Runable或Callable类线程，不能直接放入继承Thread的类

在java中，每次程序运行至少启动2个线程。一个是main线程，一个是垃圾收集线程。因为每当使用java命令执行一个类的时候，实际上都会启动一个JVM，每一个JVM其实在就是在操作系统中启动了一个进程。

1.2.5 线程的状态

当线程被创建并启动以后，它既不是一启动就进入了执行状态，也不是一直处于执行状态。在API中 java.lang.Thread.State 这个枚举中给出了六种线程状态：

线程状态	导致状态发生条件
NEW(新建)	线程刚被创建，但是并未启动，还没调用start方法。
Runnable(可运行)	线程可以在java虚拟机中运行的状态，可能正在运行自己代码，也可能没有，这取决于操作系统处理器。
Blocked(锁阻塞)	当一个线程试图获取一个对象锁，而该对象锁被其他的线程持有，则该线程进入Blocked状态；当该线程持有锁时，该线程将变成Runnable状态。
Waiting(无限等待)	一个线程在等待另一个线程执行一个（唤醒）动作时，该线程进入Waiting状态。进入这个状态后是不能自动唤醒的，必须等待另一个线程调用notify或者notifyAll方法才能够唤醒。
TimedWaiting(计时等待)	同waiting状态，有几个方法有超时参数，调用他们将进入Timed Waiting状态。这一状态将一直保持到超时期满或者接收到唤醒通知。带有超时参数的常用方法有Thread.sleep 、Object.wait。
Teminated(被终止)	因为run方法正常退出而死亡，或者因为没有捕获的异常终止了run方法而死亡。

在这里插入图片描述

1.2.5.1 Timed Waiting（计时等待）

Timed Waiting在API中的描述为：一个正在限时等待另一个线程执行一个（唤醒）动作的线程处于这一状态。

进入TIMED_WAITING 状态的一种常见情形是调用的 sleep 方法，单独的线程也可以调用，不一定非要有协作关系。
为了让其他线程有机会执行，可以将Thread.sleep()的调用放线程run()之内。这样才能保证该线程执行过程中会睡眠
sleep与锁无关，线程睡眠到期自动苏醒，并返回到Runnable（可运行）状态。

sleep()中指定的时间是线程不会运行的最短时间。因此，sleep()方法不能保证该线程睡眠到期后就开始立刻执行。

1.2.5.2 BLOCKED（锁阻塞）

Blocked状态在API中的介绍为：一个正在阻塞等待一个监视器锁（锁对象）的线程处于这一状态。

比如，线程A与线程B代码中使用同一锁，如果线程A获取到锁，线程A进入到Runnable状态，那么线程B就进入到Blocked锁阻塞状态。

1.2.5.3 Waiting（无限等待）

Wating状态在API中介绍为：一个正在无限期等待另一个线程执行一个特别的（唤醒）动作的线程处于这一状态。

当一个调用了某个对象的 Object.wait 方法的线程会等待(Waiting)另一个线程调用此对象的Object.notify()方法或 Object.notifyAll()方法。

其实waiting状态并不是一个线程的操作，它体现的是多个线程间的通信，可以理解为多个线程之间的协作关系，多个线程会争取锁，同时相互之间又存在协作关系。

当多个线程协作时，比如A，B线程，如果A线程在Runnable（可运行）状态中调用了wait()方法那么A线程就进入了Waiting（无限等待）状态，同时失去了同步锁。假如这个时候B线程获取到了同步锁，在运行状态中调用了
notify()方法，那么就会将无限等待的A线程唤醒。注意是唤醒，如果获取到锁对象，那么A线程唤醒后就进入Runnable（可运行）状态；如果没有获取锁对象，那么就进入到Blocked（锁阻塞状态）。

1.2.6 影响CPU调度的因素

Priority线程的优先级
- 1-10之间数字，默认值是5，数组越大，获取CPU的概率会提高
Thread.sleep(毫秒)：休眠
- 调用此方法，该线程会进入休眠状态，（BLOCKED），当休眠时间结束，线程继续运行
join()：加入，插入，插队
- 实例方法，谁调用谁插队，等t线程执行完，其它线程才执行
Thread.yield()：礼让
- 该代码所在线程礼让，放弃本次抢占到的时间片，重写进行下一次的抢占，可能礼让成功，也可能礼让不成功

1.3 线程安全

1.3.1 概述

如果有多个线程在同时运行，而这些线程可能会同时运行这段代码。程序每次运行结果和单线程运行的结果是一样的，而且其他的变量的值也和预期的是一样的，就是线程安全的。

卖票案例：

public class Ticket implements Runnable {
	private int ticket = 10;
	/*
	* 执行卖票操作
	*/
	@Override
	public void run() {
		//每个窗口卖票的操作
		//窗口 永远开启
		while (true) {
			if (ticket > 0) {//有票 可以卖
				//出票操作
				//使用sleep模拟一下出票时间
				try {
					Thread.sleep(100);
				} catch (InterruptedException e) {
					// TODO Auto‐generated catch block
					e.printStackTrace();
				}
				//获取当前线程对象的名字
				String name = Thread.currentThread().getName();
				System.out.println(name + "正在卖:" + ticket‐‐);
			}
		}
	}
}

public class Demo {
	public static void main(String[] args) {
		//创建线程任务对象
		Ticket ticket = new Ticket();
		//创建三个窗口对象
		Thread t1 = new Thread(ticket, "窗口1");
		Thread t2 = new Thread(ticket, "窗口2");
		Thread t3 = new Thread(ticket, "窗口3");
		//同时卖票
		t1.start();
		t2.start();
		t3.start();
	}
}

发现程序出现了两个问题：

相同的票数，比如5这张票被卖了两回。
不存在的票，比如0票与-1票，是不存在的。

线程安全问题都是由全局变量及静态变量引起的。若每个线程中对全局变量、静态变量只有读操作，而无写操作，一般来说，这个全局变量是线程安全的；若有多个线程同时执行写操作，一般都需要考虑线程同步，否则的话就可能影响线程安全。

1.3.2 线程同步

当我们使用多个线程访问同一资源的时候，且多个线程中对资源有写的操作，就容易出现线程安全问题。

要解决上述多线程并发访问一个资源的安全性问题：也就是解决重复票与不存在票问题，Java中提供了同步机制(synchronized)来解决。

卖票案例解决方法：

窗口1线程进入操作的时候，窗口2和窗口3线程只能在外等着，窗口1操作结束，窗口1和窗口2和窗口3才有机会进入代码去执行。也就是说在某个线程修改共享资源的时候，其他线程不能修改该资源，等待修改完毕同步之后，才能去抢夺CPU资源，完成对应的操作，保证了数据的同步性，解决了线程不安全的现象。

三种方式完成同步操作：

同步代码块
同步方法
锁机制

1.3.3 同步代码块

同步代码块： synchronized 关键字可以用于方法中的某个区块中，表示只对这个区块的资源实行互斥访问。

synchronized(同步锁){
	需要同步操作的代码
}

同步锁:

对象的同步锁只是一个概念，可以想象为在对象上标记了一个锁.

锁对象可以是任意类型。
多个线程对象要使用同一把锁。

在任何时候，最多允许一个线程拥有同步锁，谁拿到锁就进入代码块，其他的线程只能在外等着(BLOCKED)。

卖票案例问题解决：

public class Ticket implements Runnable{
	private int ticket = 10;
	Object lock = new Object();
	/*
	* 执行卖票操作
	*/
	@Override
	public void run() {
		//每个窗口卖票的操作
		//窗口 永远开启
		while(true){
			synchronized (lock) {
				if(ticket>0){//有票 可以卖
					//出票操作
					//使用sleep模拟一下出票时间
					try {
						Thread.sleep(50);
					} catch (InterruptedException e) {
						// TODO Auto‐generated catch block
						e.printStackTrace();
					}
					//获取当前线程对象的名字
					String name = Thread.currentThread().getName();
					System.out.println(name+"正在卖:"+ticket‐‐);
				}
			}
		}
	}
}

1.3.4 同步方法

同步方法：使用synchronized修饰的方法，就叫做同步方法，保证A线程执行该方法的时候，其他线程只能在方法外等。

public synchronized void method(){
	可能会产生线程安全问题的代码
}

对于非static方法，同步锁就是this。
对于static方法，我们使用当前方法所在类的字节码对象(类名.class)。

卖票案例问题解决：

public class Ticket implements Runnable{
	private int ticket = 10;
	/*
	* 执行卖票操作
	*/
	@Override
	public void run() {
		//每个窗口卖票的操作
		//窗口 永远开启
		while(true){
			sellTicket();
		}
	}
	/*
	* 锁对象 是 谁调用这个方法 就是谁
	* 隐含 锁对象 就是 this
	*
	*/
	public synchronized void sellTicket(){
		if(ticket>0){//有票 可以卖
			//出票操作
			//使用sleep模拟一下出票时间
			try {
				Thread.sleep(100);
			} catch (InterruptedException e) {
				// TODO Auto‐generated catch block
				e.printStackTrace();
			}
			//获取当前线程对象的名字
			String name = Thread.currentThread().getName();
			System.out.println(name+"正在卖:"+ticket‐‐);
		}
	}
}

1.3.5 锁机制

java.util.concurrent.locks.Lock 机制提供了比synchronized代码块和synchronized方法更广泛的锁定操作，同步代码块/同步方法具有的功能Lock都有，除此之外更强大,更体现面向对象。

Lock锁也称同步锁，加锁与释放锁方法化了，如下：

public void lock()：加同步锁。
public void unlock()：释放同步锁。

卖票案例问题解决：

public class Ticket implements Runnable{
	private int ticket = 10;
	Lock lock = new ReentrantLock();
	/*
	* 执行卖票操作
	*/
	@Override
	public void run() {
		//每个窗口卖票的操作
		//窗口 永远开启
		while(true){
			lock.lock();
			if(ticket>0){//有票 可以卖
				//出票操作
				//使用sleep模拟一下出票时间
				try {
					Thread.sleep(50);
				} catch (InterruptedException e) {
					// TODO Auto‐generated catch block
					e.printStackTrace();
				}
				//获取当前线程对象的名字
				String name = Thread.currentThread().getName();
				System.out.println(name+"正在卖:"+ticket‐‐);
			}
			lock.unlock();
		}
	}
}

1.3.6 同步代码块和同步方法的区别

一个方法内部可以出现多个同步代码块，且同步代码块可以嵌套
一个线程在访问同步方法，其它的线程都不能访问所有的同步方法，只能访问非同步的方法
同步代码块更灵活，同步方法可以重用

线程安全的类：

StringBuilder：非线程安全，效率高，适合单线程
StringBuffer：线程安全，效率低，适合多线程
HashMap：非线程安全，key可以null
Hashtable：线程安全，key不能为null
ArrayList：数组列表，非线程安全
Vector：向量，线程安全

1.4 死锁和生产消费问题

1.4.1 死锁

死锁：在多线程中，每个线程都拥有对方想要的锁，同时又等待对方给他锁。

案例描述：

小花：拿着洋娃娃 --你把你的小汽车给我，我就把我洋娃娃给你
小明：拿着小汽车–你把你的洋娃娃给我，我就把我小汽车给你

小花线程：

public class XiaoHua implements Runnable{
	private Object baby;
	private Object car;
	
	public XiaoHua(Object baby,Object car) {
		this.baby=baby;
		this.car=car;
	}
	
	@Override
	public void run() {
	//		try {
//			Thread.sleep(3000);
//		} catch (InterruptedException e) {
//			e.printStackTrace();
//		}
		synchronized (baby) {
			System.out.println("小花拿到了洋娃娃");
			
			synchronized (car) {
				System.out.println("小花拿到了小汽车");
			}
		}
	}
}

小明线程：

public class Xiaoming implements Runnable{
	private Object baby;
	private Object car;
	
	public Xiaoming(Object baby,Object car) {
		this.baby=baby;
		this.car=car;
	}
	@Override
	public void run() {
		synchronized (car) {
			System.out.println("小明拿到了小汽车");
			
			synchronized (baby) {
				System.out.println("小明拿到了洋娃娃");
			}	
		}
	}
}

测试类：

public class Test {

	public static void main(String[] args) {
		Object baby=new Object();
		Object car=new Object();
		Thread t=new Thread(new XiaoHua(baby,car));
		Thread t2=new Thread(new Xiaoming(baby,car));
		t.start();
		t2.start();
	}
}

结果发现，两个线程一直运行，陷入死锁状态。

原因：同步代码块的嵌套，同步代码块可能产生死锁，但不是一定产生死锁

解决方案：使用外力，可以在小花或小明线程其中的一个，使其启动时就休眠，使另外一个线程获取到两个玩具，然后在释放锁，使另一个恢复运行态的线程得到两个玩具锁。

1.4.2 生产消费问题

1.4.2.1 等待唤醒机制

线程间通信

概念：多个线程在处理同一个资源，但是处理的动作（线程的任务）却不相同。

比如：线程A用来生成包子的，线程B用来吃包子的，包子可以理解为同一资源，线程A与线程B处理的动作，一个是生产，一个是消费，那么线程A与线程B之间就存在线程通信问题。

如何保证线程间通信有效利用资源：

多个线程在处理同一个资源，并且任务不同时，需要线程通信来帮助解决线程之间对同一个变量的使用或操作。就是多个线程在操作同一份数据时，避免对同一共享变量的争夺。也就是我们需要通过一定的手段使各个线程能有效的利用资源。而这种手段即—— 等待唤醒机制。

等待唤醒机制：

就是在一个线程进行了规定操作后，就进入等待状态（wait()），等待其他线程执行完他们的指定代码过后再将其唤醒（notify()），在有多个线程进行等待时，如果需要，可以使用 notifyAll()来唤醒所有的等待线程。

等待唤醒中的方法:

等待唤醒机制就是用于解决线程间通信的问题的，使用到的3个方法的含义如下：

wait：线程不再活动，不再参与调度，进入 wait set 中，因此不会浪费 CPU 资源，也不会去竞争锁了，这时的线程状态即是 WAITING。它还要等着别的线程执行一个特别的动作，也即是“通知（notify）”在这个对象上等待的线程从wait set 中释放出来，重新进入到调度队列（ready queue）中
notify：则选取所通知对象的 wait set 中的一个线程释放；例如，餐馆有空位置后，等候就餐最久的顾客最先入座。
notifyAll：则释放所通知对象的 wait set 上的全部线程。

哪怕只通知了一个等待的线程，被通知线程也不能立即恢复执行，因为它当初中断的地方是在同步块内，而此刻它已经不持有锁，所以她需要再次尝试去获取锁（很可能面临其它线程的竞争），成功后才能在当初调用 wait 方法之后的地方恢复执行。
总结如下：
如果能获取锁，线程就从 WAITING 状态变成 RUNNABLE 状态；
否则，从 wait set 出来，又进入 entry set，线程就从 WAITING 状态又变成 BLOCKED 状态

调用wait和notify方法需要注意的细节

wait方法与notify方法必须要由同一个锁对象调用。因为：对应的锁对象可以通过notify唤醒使用同一个锁对象调用的wait方法后的线程。
wait方法与notify方法是属于Object类的方法的。因为：锁对象可以是任意对象，而任意对象的所属类都是继承了Object类的。
wait方法与notify方法必须要在同步代码块或者是同步函数中使用。因为：必须要通过锁对象调用这2个方法。

1.4.2.2 生产消费者问题解决

生产者：

//生产20个
public class Productor implements Runnable{
	private Production pro;
	
	public Productor(Production pro) {
		this.pro=pro;
	}

	@Override
	public void run() {
		for (int i = 1; i <=20; i++) {
			pro.set("名称"+i, "描述"+i);
		}
	}
}

消费者：

public class Consumer implements Runnable{
	private Production pro;
	
	public Consumer(Production pro) {
		this.pro=pro;
	}
	
	@Override
	public void run() {
		for (int i = 1; i <=20; i++) {
			pro.get();
		}
	}
}

产品类：

public class Production {
	private String name;
	private String desc;
	
	public String getName() {
		return name;
	}
	public void setName(String name) {
		this.name = name;
	}
	public String getDesc() {
		return desc;
	}
	public void setDesc(String desc) {
		this.desc = desc;
	}
	boolean flag=true;//true 只生产  false 消费
	
	public synchronized void set(String name,String desc) {
		if(!flag) {
			try {
				wait();//等待
			} catch (InterruptedException e) {
				e.printStackTrace();
			}
		}
		
		setName(name);
		
		try {
			Thread.sleep(10);
		} catch (InterruptedException e) {
			e.printStackTrace();
		}
		
		setDesc(desc);
		flag=false;
		notify();//解除其它阻塞的线程，唤醒
	}
	
	public synchronized void get() {
		if(flag) {
			//还未生产好
			try {
				wait();
			} catch (InterruptedException e) {
				e.printStackTrace();
			}
		}
		
		try {
			Thread.sleep(50);
		} catch (InterruptedException e) {
			e.printStackTrace();
		}
		System.out.println(getName()+" "+getDesc());
		flag=true;
		notify();
	}
}

测试类：

public class Test {
	public static void main(String[] args) {
		Production pro=new Production();
		Thread p=new Thread(new Productor(pro));
		Thread c=new Thread(new Consumer(pro));
		p.start();
		c.start();
	}
}

1.5 线程池

1.5.1 线程池思想概述

我们使用线程的时候就去创建一个线程，这样实现起来非常简便，但是就会有一个问题：

如果并发的线程数量很多，并且每个线程都是执行一个时间很短的任务就结束了，这样频繁创建线程就会大大降低系统的效率，因为频繁创建线程和销毁线程需要时间，在Java中可以通过线程池来达到这样的效果。

1.5.2 线程池概念

线程池：其实就是一个容纳多个线程的容器，其中的线程可以反复使用，省去了频繁创建线程对象的操作，无需反复创建线程而消耗过多资源。

合理利用线程池能够带来三个好处：

降低资源消耗。减少了创建和销毁线程的次数，每个工作线程都可以被重复利用，可执行多个任务。
提高响应速度。当任务到达时，任务可以不需要的等到线程创建就能立即执行。
提高线程的可管理性。可以根据系统的承受能力，调整线程池中工作线线程的数目，防止因为消耗过多的内存，而把服务器累趴下(每个线程需要大约1MB内存，线程开的越多，消耗的内存也就越大，最后死机)。
可以定时定期执行一定的任务。

1.5.3 线程池的使用

Java里面线程池的顶级接口是java.util.concurrent.Executor，但是严格意义上讲Executor并不是一个线程池，而只是一个执行线程的工具。真正的线程池接口是java.util.concurrent.ExecutorService。

线程池体系结构：

顶级接口：Executor
- 子接口：ExecutorService
  - 抽象类：AbstractExecutorService
    - 实现类：ThreadPoolExecutor
  - 接口：ScheduledExecutorService
    - 实现类：ScheduledThreadPoolExecutor

工具类Executors：创建线程池对象

static ExecutorService newCachedThreadPool()：创建可缓存线程的线程池
static ExecutorService newFixedThreadPool(int nThreads)：创建固定线程数的线程池
static ScheduledExecutorService newScheduledThreadPool(int corePoolSize)：创建周期性执行的线程池
static ExecutorService newSingleThreadExecutor()：创建单线程的线程池

使用线程池中线程对象的步骤：

创建线程池对象。
创建Runnable接口子类对象。(task)
提交Runnable接口子类对象。(take task)
关闭线程池(一般不做)。

1.5.3.1 创建单线程的线程池

创建线程任务对象：

public class MyRunnable implements Runnable{
	int num;
	public MyRunnable(int num) {
		this.num=num;
	}

	@Override
	public void run() {
		System.out.println(Thread.currentThread().getName()+"  "+num);
		try {
			Thread.sleep(100);
		} catch (InterruptedException e) {
			e.printStackTrace();
		}
	}
}

测试类：

public class TestPool {
	public static void main(String[] args) {
//		ExecutorService pool=Executors.newCachedThreadPool();
//		ExecutorService pool=Executors.newFixedThreadPool(3);
		ExecutorService pool=Executors.newSingleThreadExecutor();
		for (int i = 1; i <=10; i++) {
			pool.execute(new MyRunnable(i));
			try {
				Thread.sleep(10);
			} catch (InterruptedException e) {
				e.printStackTrace();
			}
		}
		pool.shutdown();
	}
}

1.5.3.2 创建周期性执行的线程池

public class TestScheduledPool {
	public static void main(String[] args) {
		ScheduledExecutorService pool=Executors.newScheduledThreadPool(3);
		System.out.println("开始执行");
		//参数1为任务对象，参数2为开始的间隔时间，参数3为每隔多少时间执行
		pool.scheduleAtFixedRate(new MyRunnable(1), 1, 2, TimeUnit.SECONDS);
	}
}

1.5.4 自定义线程

自定义线程类使用ThreadPoolExecutor，其中定义的参数描述如下：

public ThreadPoolExecutor(
int corePoolSize, 核心线程数
int maximumPoolSize, 最大线程数
long keepAliveTime, 最大空闲时间
TimeUnit unit, 最大空闲时间使用的单位
BlockingQueue workQueue, 阻塞队列，等待的队列
ThreadFactory threadFactory, 线程工厂，创建线程
RejectedExecutionHandler handler 拒绝策略
）

import java.util.concurrent.LinkedBlockingDeque;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

public class TestMyPool {
	public static void main(String[] args) {
		ThreadPoolExecutor pool=new ThreadPoolExecutor(
				5, 7, 300, TimeUnit.MICROSECONDS,
				new LinkedBlockingDeque<Runnable>(4),
				new ThreadPoolExecutor.DiscardPolicy()
				//RejectedExecutionException 
				);
		for (int i = 1; i <=12; i++) {
			pool.execute(new MyRun(i));
			System.out.println("线程数量："+pool.getPoolSize()
			+",阻塞队列："+pool.getQueue().size()
			+",完成任务数："+pool.getCompletedTaskCount());
		}
		pool.shutdown();
	}

}

class MyRun implements Runnable{
	int num;
	public MyRun(int num) {
		this.num=num;
	}

	@Override
	public void run() {
		try {
			Thread.sleep(2000);
		} catch (InterruptedException e) {
			e.printStackTrace();
		}
		
	}
}

原文链接：https://blog.csdn.net/qq_44292366/article/details/115652973

java笔记（第五部分多线程）

目录

一、多线程

1.1 多线程概述

1.1.1 并发与并行

1.1.2 线程与进程

1.2 线程的创建与状态

1.2.1 Thread类

1.2.2 继承Thread方式创建线程

1.2.3 实现接口方式创建线程

1.2.4 Thread和Runnable创建线程的区别

1.2.5 线程的状态

1.2.5.1 Timed Waiting（计时等待）

1.2.5.2 BLOCKED（锁阻塞）

1.2.5.3 Waiting（无限等待）

1.2.6 影响CPU调度的因素

1.3 线程安全

1.3.1 概述

1.3.2 线程同步

1.3.3 同步代码块

1.3.4 同步方法

1.3.5 锁机制

1.3.6 同步代码块和同步方法的区别

1.4 死锁和生产消费问题

1.4.1 死锁

1.4.2 生产消费问题

1.4.2.1 等待唤醒机制

1.4.2.2 生产消费者问题解决

1.5 线程池

1.5.1 线程池思想概述

1.5.2 线程池概念

1.5.3 线程池的使用

1.5.3.1 创建单线程的线程池

1.5.3.2 创建周期性执行的线程池

1.5.4 自定义线程