Java之同步锁

2年前 (2022) 程序员胖胖胖虎阿

137 0 0

同步代码块

加锁的为需要被同步的代码
共享数据，多个线程都需要操作的数据
同步监视器，即锁，任何一个对象都可以成为锁。、
1. 要求：锁必须是唯一的，多线程之间必须共用一把锁
2. 实现Runnable接口时，我们可以考虑使用this充当同步监视器
3. 使用Thread继承时我们可以使用类名.class作为同步监视器
```
synchronized（同步监视器）{
	需要同步的代码
}
```

同步方法

如果操作共享数据的代码完整的声明在一个方法中，我们不妨使用此方法声明同步
同步方法中仍然涉及到同步监视器，只是不需要我们显示的声明。非静态方法为this，静态方法为类本身

 实现Runnable
public class HeapDemo implements Runnable{

    private int t = 100;
    @Override
    public void run() {
        while (true) {
           show();
        }
    }
    private synchronized void show(){
        if (t > 0) {
            try {
                Thread.sleep(100);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println(Thread.currentThread().getName() + ":" + t);
            t--;
        }
    }
}
class tews{
    public static void main(String[] args) {
        HeapDemo heapDemo = new HeapDemo();

        Thread thread = new Thread(heapDemo);
        Thread thread1 = new Thread(heapDemo);
        Thread thread2 = new Thread(heapDemo);
//        System.err.println(thread.getClass());
//        System.err.println(thread1.getClass());
        thread.setName("线程一");
        thread1.setName("线程二");
        thread2.setName("线程三");
        thread.start();
        thread1.start();
        thread2.start();
    }
}

实现继承
public class HeapDemo extends Thread{

    private static int t = 100;
    @Override
    public void run() {
        while (true) {
           show();
        }
    }
    private static synchronized void show(){
        if (t > 0) {
            try {
                Thread.sleep(100);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println(Thread.currentThread().getName() + ":" + t);
            t--;
        }
    }
}
class tews{
    public static void main(String[] args) {
    
    +++++++++++++++++++++++++++++++++++++++++++++++++
        HeapDemo heapDemo = new HeapDemo();
        HeapDemo heapDemo1 = new HeapDemo();
        HeapDemo heapDemo2 = new HeapDemo();
	 +++++++++++++++++++++++++++++++++++++++++++++++++ 
        
        
        heapDemo.setName("线程一");
        heapDemo1.setName("线程二");
        heapDemo2.setName("线程三");
        heapDemo.start();
        heapDemo1.start();
        heapDemo2.start();
    }
}

Lock

jdk5.0开始，Java提供了更强大的线程同步机制——通过显式定义同步锁对象实现同步，同步锁使用Lock对象充当。

java.util.concurrent.locks.Lock接口是控制多个线程对共享资源进行访问的工具，锁提供了对共享资源的独立访问，每次只能有一个线程对Lock对象加锁，线程开始访问共享资源之前应先获得Lock对象。

ReentrantLock类实现了Lock，它拥有与synchronized相同的并发性和内存语义，在实现线程安全控制中，比较常用的是ReentrantLock，可以显式加锁，释放锁

public class HeapDemo implements Runnable{

    private  int t = 100;
    ReentrantLock lock = new ReentrantLock();
    @Override
    public void run() {
        while (true) {
            try {
                lock.lock();
                if (t > 0) {
                    try {
                        Thread.sleep(100);
                    } catch (InterruptedException e) {
                        e.printStackTrace();
                    }
                    System.out.println(Thread.currentThread().getName() + ":" + t);
                    t--;
                }else{
                    break;
                }
            }finally {
                lock.unlock();
            }
        }
    }


}
class tews{
    public static void main(String[] args) {
        
        HeapDemo heapDemo = new HeapDemo();

        Thread thread = new Thread(heapDemo);
        Thread thread1 = new Thread(heapDemo);
        Thread thread2 = new Thread(heapDemo);
        thread.setName("线程一");
        thread1.setName("线程二");
        thread2.setName("线程三");
        thread.start();
        thread1.start();
        thread.start();
    }
}