Java 基础(线程的生命周期, 同步代码块解决线程安全)

线程的生命周期

JDK 中用 Thread.state 类定义了线程的几种状态
要想实现多线程,必须在主线程中创建新的线程对象。Java语言使用 Thread 类及其子类的对象来表示线程,在它的一个完整的生命周期中通常要经历如下的五种状态:

  1. 新建: 当一个Thread类或其子类的对象被声明并创建时,新生的线程对象处于新建状态
  2. 就绪: 处于新建状态的线程被 start() 后,将进入线程队列等待CPU时间片,此时它已具备了运行的条件,只是没分配到CPU资源
  3. 运行: 当就绪的线程被调度并获得 CPU 资源时,便进入运行状态,run()方法定义了线程的操作和功能
  4. 阻塞: 在某种特殊情况下,被人为挂起或执行输入输出操作时,让出 CPU 并临时中止自己的执行,进入阻塞状态
  5. 死亡: 线程完成了它的全部工作或线程被提前强制性地中止或出现异常导致结束

Java 基础(线程的生命周期, 同步代码块解决线程安全)

同步代码块解决线程安全

在Java中,我们通过同步机制,来解决线程的安全问题。

方式一:同步代码块
synchronized(同步监视器){
   //需要被同步的代码
}


 说明:1.操作共享数据的代码,即为需要被同步的代码 -->不能包含代码多了,也不能包含代码少了。
     2.共享数据: 多个线程共同操作的变量。比如: ticket就是共享数据。
     3.同步监视器,俗称:锁。任何一个类的对象,都可以充当锁。
       要求:多个线程必须要共用同一把锁。

在实现Runnable接口创建多线程的方式中,我们可以考虑使用this充当同步监视器。

package com.klvchen.java;

class Window1 implements Runnable{
    private int ticket = 100;
//    Object obj = new Object();

    @Override
    public void run() {
        while (true){
            synchronized (this){//此时的this:唯一的window1的对象
                if (ticket > 0){
                    try {
                        Thread.sleep(100);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }

                    System.out.println(Thread.currentThread().getName() + ":卖票,票号为" + ticket);
                    ticket--;
                }else {
                    break;
                }

            }
        }

    }
}

public class WindowTest1 {
    public static void main(String[] args) {
        Window1 w = new Window1();

        Thread t1 = new Thread(w);
        Thread t2 = new Thread(w);
        Thread t3 = new Thread(w);

        t1.setName("窗口1");
        t2.setName("窗口2");
        t3.setName("窗口3");

        t1.start();
        t2.start();
        t3.start();
    }
}

在继承Thread类创建多线程的方式中,慎用this充当同步监视器,考虑使用当前类充当同步监视器

package com.klvchen.java;

class Window2 extends Thread{

    private static int ticket = 100;

//    private static Object obj = new Object();

    @Override
    public void run(){
        while (true){
            //错误的方式:此时的this代表着 t1,t2,t3 三个对象
//            synchronized (this)
            //正确的方式:
//            synchronized (obj){
            synchronized (Window2.class){
                if (ticket > 0){

                    try {
                        Thread.sleep(100);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }

                    System.out.println(getName() + "卖票,票号为: " + ticket);
                    ticket--;
                }else {
                    break;
                }

            }
        }
    }
}
public class WindowTest2 {
    public static void main(String[] args) {
        Window2 t1 = new Window2();
        Window2 t2 = new Window2();
        Window2 t3 = new Window2();

        t1.setName("线程1");
        t2.setName("线程2");
        t3.setName("线程3");

        t1.start();
        t2.start();
        t3.start();

    }
}

 

上一篇:Java 基础(同步方法解决线程安全问题)


下一篇:分布式事务中的一致性和隔离性