当我以为我的代码很安全时，等等。。。

目录

多线程的基本概念

基本概念：程序、进程、线程

单核CPU和多核CPU的理解

​ 

并行与并发

使用多线程的优点

​ 

何时需要多线程

​ 

线程的创建和使用

​

 创建多线程的方式一

注意点：

​ 

继承方式实现多线程代码示例： 

线程的常用方法

​​

线程的调度

​ 

线程的优先级

​ ​

 补充：线程的分类

创建多线程的方式二

​ 

实现方式实现多线程代码示例：

 两种实现多线程方式的比较

线程的生命周期

​ ​

线程的同步

问题的提出

​ 

案例分析：火车站售票

理想状态

​ 

极端状态

​ 

问题分析

​ 

 Synchronized的使用方法

分析同步原理： 

同步机制中的锁

​ 

 同步的范围

释放锁的操作

​ 

不会释放锁的操作

​ 

方式一：同步代码块

​ 

 继承方式的线程同步处理

代码实现：

 

实现方式的线程同步处理

代码实现：

 

方式二：同步方法

实现方式的线程同步处理

 代码实现：

继承方式的线程同步处理

  代码实现：

同步方法的总结

线程安全的单例懒汉式 

线程的死锁问题 

方法三：Lock锁

​

synchronized 与 Lock 的对比

线程的通信

wait() 与 notify() 和 notifyAll()

​

 sleep()和wait()

线程通信的经典案例：

​ ​

创建多线程的方式三

 实现Callable接口

创建多线程的方式四

使用线程池

使用线程池的好处 

使用线程池的方式 

---

多线程的基本概念

基本概念：程序、进程、线程

 

单核CPU和多核CPU的理解

 

并行与并发

使用多线程的优点

 

何时需要多线程

 

---

线程的创建和使用

---

 创建多线程的方式一

 

注意点：

 

继承方式实现多线程代码示例： 

package com.ykx.java;/*** @author yangkx* @create 2022-01-24 17:42*/
public class HelloWorld {public static void main(String[] args) {MyThread t = new MyThread();t.start();for(int i = 0; i < 100; i++)if(i % 2 != 0)System.out.println(i+"=====main");}
}
class MyThread extends Thread{@Overridepublic void run() {for(int i = 0; i < 100; i++)if(i % 2 == 0)System.out.println(i);}
}

 

 

---

线程的常用方法

 

---

线程的调度

 

---

线程的优先级

 

---

 补充：线程的分类

 

---

创建多线程的方式二

 

实现方式实现多线程代码示例：

public class ThreadDemo {public static void main(String[] args) {//③创建该类的对象MThread mThread = new MThread();//④将此对象作为参数，传递到Thread构造器中，创建对象Thread thread = new Thread(mThread);//⑤调用start()方法thread.start();}
}
//①类实现Runnable接口
class MThread implements Runnable{//重写run方法@Overridepublic void run() {for(int i = 0 ; i < 100; i++)if(i % 2 == 0 )System.out.println(i);}
}

 

 两种实现多线程方式的比较

 

---

线程的生命周期

 

---

线程的同步

问题的提出

 

案例分析：火车站售票

模拟火车站售票，开启三个窗口售票

理想状态

 

极端状态

 

问题分析

 

 Synchronized的使用方法

 

分析同步原理： 

 

同步机制中的锁

 

 同步的范围

释放锁的操作

 

不会释放锁的操作

 

 

---

方式一：同步代码块

 

 继承方式的线程同步处理

代码实现：

package com.ykx.java;/*** @author: yangkx* @Title: WindowTest* @ProjectName: JavaSenior* @Description:* @date: 2022/1/27 15:57* 同步代码块处理继承方式的多线程*/
public class WindowTest1 {public static void main(String[] args) {Window1 window1 = new Window1();Window1 window2 = new Window1();Window1 window3 = new Window1();window1.setName("窗口一");window2.setName("窗口二");window3.setName("窗口三");window1.start();window2.start();window3.start();}
}class Window1 extends Thread {private static int ticket = 20;@Overridepublic void run() {while (true) {synchronized (Window1.class) {if (ticket > 0) {try {Thread.sleep(100);} catch (InterruptedException e) {e.printStackTrace();}System.out.println(Thread.currentThread().getName() + ":售票 号：" + ticket);ticket--;} else {break;}}}}
}

 

实现方式的线程同步处理

代码实现：

package com.ykx.java;/*** @author: yangkx* @Title: WindowTest2* @ProjectName: JavaSenior* @Description:* @date: 2022/1/27 16:57* 同步代码块处理实现方式的多线程*/
public class WindowTest2 {public static void main(String[] args) {Window2 window2 = new Window2();Thread thread1 = new Thread(window2);Thread thread2 = new Thread(window2);Thread thread3 = new Thread(window2);thread1.setName("窗口一");thread2.setName("窗口二");thread3.setName("窗口三");thread1.start();thread2.start();thread3.start();}
}class Window2 implements Runnable {private static int ticket = 20;@Overridepublic void run() {while (true) {synchronized (this) {if (ticket > 0) {try {Thread.sleep(100);} catch (InterruptedException e) {e.printStackTrace();}System.out.println(Thread.currentThread().getName() + ":售票 号：" + ticket);ticket--;} else {break;}}}}
}

 

方式二：同步方法

实现方式的线程同步处理

方法：

例子：

 

 代码实现：

package com.ykx.java;/*** @author: yangkx* @Title: WindowTest3* @ProjectName: JavaSenior* @Description:* @date: 2022/1/27 16:57* 同步方法处理实现方式的多线程*/
public class WindowTest3 {public static void main(String[] args) {Window3 window3 = new Window3();Thread thread1 = new Thread(window3);Thread thread2 = new Thread(window3);Thread thread3 = new Thread(window3);thread1.setName("窗口一");thread2.setName("窗口二");thread3.setName("窗口三");thread1.start();thread2.start();thread3.start();}
}class Window3 implements Runnable {private static int ticket = 20;@Overridepublic void run() {while (true) {if(ticket > 0)show();else break;}}private synchronized void show(){if (ticket > 0) {try {Thread.sleep(100);} catch (InterruptedException e) {e.printStackTrace();}System.out.println(Thread.currentThread().getName() + ":售票 号：" + ticket);ticket--;}}
}

 

继承方式的线程同步处理

因为继承方式造了多个不同对象，所以this是不一样的。加上static后同步监视器是class 

  代码实现：

package com.ykx.java;/*** @author: yangkx* @Title: WindowTest4* @ProjectName: JavaSenior* @Description:* @date: 2022/1/27 16:58* 同步方法处理继承方式的多线程*/
public class WindowTest4 {public static void main(String[] args) {Window4 window1 = new Window4();Window4 window2 = new Window4();Window4 window3 = new Window4();window1.setName("窗口一");window2.setName("窗口二");window3.setName("窗口三");window1.start();window2.start();window3.start();}
}
class Window4 extends Thread{private static int ticket = 20;@Overridepublic void run() {while(true){if(ticket > 0)show();else break;}}private static synchronized void show(){if (ticket > 0) {try {Thread.sleep(100);} catch (InterruptedException e) {e.printStackTrace();}System.out.println(Thread.currentThread().getName() + ":售票 号：" + ticket);ticket--;}}
}

同步方法的总结

线程安全的单例懒汉式 

 

---

线程的死锁问题 

方法三：Lock锁

 

 

synchronized 与 Lock 的对比

---

线程的通信

wait() 与 notify() 和 notifyAll()

 

 sleep()和wait()

线程通信的经典案例：

 

 

 

---

创建多线程的方式三

 实现Callable接口

 

---

创建多线程的方式四

使用线程池

使用线程池的好处 

 

使用线程池的方式