一.创建线程的两种方式
1.继承Thread类,重写run方法
- 直接代码实操
public class Thread_ {
public static void main(String[] args) {
Cat cat = new Cat();
cat.start();
System.out.println("主线程继续执行"+Thread.currentThread().getName());
int i=0;
while(i==30){
System.out.println("主线程 "+i++);
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
class Cat extends Thread {
int time;
@Override
public void run() {
while (true) {
System.out.println("今天我们学线程" + time+++Thread.currentThread().getName());
try {
Thread.sleep(1000);
} catch (Exception e) {
e.printStackTrace();
}
if (time == 30)
break;
}
}
}
===========================================================================================
- 当我们运行程序的后我们大开终端 输入jconsole打开jconsole
- 找到我们刚刚运行的程序 进行连接
- - 随后在线程中我们可以清楚的看到 main线程和Thread-0线程
- 当main线程中的相应代码运行结束后 main线程也会 消失
- 而当Thread-0线程运行结束后并不会消失 这是因为当它运行结束后整个进程就结束死亡了
由上可得:在线程中主线程结束,如果还有相应的子线程正在进行,整个进程并不会结束
- 为什么我们不直接调用
run 方法而是使用不知道哪来的start 方法呢?
- 我们把start方法注释掉,直接调用run方法进行测试,我们可以看到并没有创建新的线程 而是直接在main方法中运行的
- 而且会等run方法全部执行完成后再往下进行
得出结论
- run方法就是一个普通的方法,并不会真正启动一个线程
- 而start方法会新建一个线程来运行run方法
2.实现Runnable接口,重写run方法
- 因为java是单继承的,在某些情况下一个类可能已经继承了某个父类,这个时候就无法再使用继承Thread类的方法来创建线程了
- 此时 我们便可以通过实现Runnable接口来创建线程
package com.java.xiancheng;
public class Thread_Runnable_ {
public static void main(String[] args) {
Hpj hpj = new Hpj();
Thread thread = new Thread(hpj);
thread.start();
}
}
class Hpj implements Runnable {
int counter = 0;
@Override
public void run() {
while (true) {
System.out.println("小侯今天学线程" + counter++ + Thread.currentThread().getName());
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
3.通过编写模拟售票代码来发现问题
package com.java.day6;
public class MaiPiao {
public static void main(String args[]) {
Ticket ticket = new Ticket();
Thread t1 = new Thread(ticket,"一号窗口");
Thread t2 = new Thread(ticket,"二号窗口");
Thread t3 = new Thread(ticket,"三号窗口");
Thread t4 = new Thread(ticket,"四号窗口");
t1.start();
t2.start();
t3.start();
t4.start();
}
static class Ticket implements Runnable {
private static int tickets = 50;
public Ticket() {
super();
}
@Override
public void run() {
while (true) {
if (tickets <= 0)
break;
System.out.println(Thread.currentThread().getName()+"...这是第" + tickets-- + "号票");
try {
Thread.sleep(100);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
}
- 经过几次测试 我们会发现买票的过程中会发现一票多卖的情况出现,而且票的顺序也是打乱的
- 当我们把循环结束的条件改为如果票数等于0就退出循环时,甚至出现了卖出负票的情况
- 我们该如何解决这个问题呢?我们在随后的学习中便能解决这个问题,请慢慢往下看
二.线程中常用的方法
1.yield和join
- yield:线程礼让,让出cpu,让其他线程执行,但是礼让的时间不确定,由cpu决定所以不一定能礼让成功
- join:线程的插队,插队的线程一旦插队成功则肯定先执行完插入的线程的所有的任务
- 代码实操:
package com.java.xiancheng;
public class Join_yield {
public static void main(String[] args) {
Hpj1 hpj = new Hpj1();
Thread h = new Thread(hpj);
h.start();
for (int i = 1; i <= 10; i++) {
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("小侯2学线程的第" + i + "分钟");
if (i == 5) {
try {
System.out.println("小侯2学了五分钟了,先让小侯学");
h.join();
System.out.println("小侯学完了我再学");
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
}
class Hpj1 implements Runnable {
int num = 1;
@Override
public void run() {
while (num <= 10) {
try {
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
System.out.println("小侯学线程的第" + num++ + "分钟");
}
}
}
- 通过运行结果可以看出 join成功的让main线程再达到条件后先让 h线程线运行完再回来运行
- 而我们把
join 换成yield 后,让了一会儿后cpu觉得我能处理过来,边又恢复了原状
三.线程的状态
线程状态 | 名称 | 描述 |
---|
new | 新建 | 线程刚被创建,还没调用start方法,或者刚刚调用了start方法,调用 start方法不一定"立即"改变线程状态,中间可能需要一些步骤才完成 一个线程的启动。 | RUNNABLE | 可运行 | start方法调用结束,线程由NEW变成RUNNABLE,线程存活着,并尝试 抢占CPU资源,或者已经抢占到CPU资源正在运行,这俩种情况的状 态都显示为RUNNABLE | BLOCKED | 锁阻塞 | 线程A和线程B都要执行方法test,而且方法test被加了锁,线程A先拿 到了锁去执行test方法,线程B这时候需要等待线程A把锁释放。这时 候线程B就是处理BLOCKED | WAITING | 无限期等待 | 一个线程在等待另一个线程执行一个(唤醒)动作时,该线程进入 Waiting状态。进入这个状态后是不能自动唤醒的,必须等待另一个线 程调用notify或者notifyAll方法才能够唤醒。 | TIMED_WAITING | 有限期等待 | 和WAITING状态类似,但是有一个时间期限,时间到了,自己也会主 动醒来 | TERMINATED | 终止(死亡) | run方法执行结束的线程处于这种状态。 |
四.线程同步机制
1. 线程同步机制理解
- 在多线程编程中,一些敏感的数据不允许被多个线程同时访问,此时就使用同步访问技术,保证数据在任何时刻,最多有一个线程访问,以保证数据的完整性
- 也可以理解为:当有一个线程在对内存进行操作的时候,其它线程都不可以对这个内存地址进行操作,直到该线程完成操作,其它线程才能对该内存地址进行操作
2.那么怎么实现线程同步呢
- 同步代码块
synchronized(对象){
}
```
synchronized 也可以放在方法的声明当中,表示整个方法 为同步方法 public synchronized void hpj(String name){
}
```
- 现在我们便可以解决上面售票代码出现的错误
- 直接把锁加在run方法上
public synchronized void run() {
}
- 程序运行后我们发现只有一个线程在买票,这是因为当第一个线程抢到锁后 会把run方法中的代码全部执行完毕才会释放锁来让其它线程去运行, 当其它线程抢到锁以后run方法结束条件已成立,最后程序就结束了
- 所以这个方法不可行
- 加在
while 循环中 可行 synchronized 关键字修饰非静态方法,默认使用 this 当做锁对象,并且不能自己另外指定synchronized 关键字修饰静态方法,默认使用 当前类的Class对象 当做锁对象,并且不能自己另外指 定
3.线程的死锁
public class ThreadDeadLock extends Thread{
private Object obj1;
private Object obj2;
public ThreadDeadLock(Object obj1,Object obj2) {
this.obj1 = obj1;
this.obj2 = obj2;
}
public void run() {
String name = Thread.currentThread().getName();
if("Thread-0".equals(name)){
while(true){
synchronized (obj1) {
synchronized (obj2) { System.out.println(name+" 运行了..");
} }
} }
else{
while(true){
synchronized (obj2) {
synchronized (obj1) {
System.out.println(name+" 运行了.."); }
} }
} }
public static void main(String[] args) {
Object obj1 = new Object();
Object obj2 = new Object();
Thread t1 = new ThreadDeadLock(obj1,obj2);
Thread t2 = new ThreadDeadLock(obj1,obj2);
t1.start();
t2.start();
}
}
|