1.为什么要同步访问数据?
当两个或以上的线程需要共享对同一数据的存取,可能会发生共享数据的讹误。
2.实现同步的方式
2.1 ReentrantLock类
School类:
class School{ private int stuNum; private Lock lock; private Condition condition; public School(int stuNum) { this.stuNum = stuNum; lock = new ReentrantLock(); condition = lock.newCondition(); } ......
其中 lock是锁对象, condition 是条件对象,
用法:
public void stuNums1(){ lock.lock(); try{ while (stuNum < 20){ System.out.println(stuNum+" < 20,等待数量变为20"); condition.await(); } stuNum -= 5; System.out.println(Thread.currentThread().toString() + ":" + stuNum); } catch (InterruptedException e) { e.printStackTrace(); } finally { lock.unlock(); } } public void stuNums2(){ lock.lock(); try{ stuNum += 1; System.out.println(Thread.currentThread().toString() + ":" + stuNum); if (stuNum >= 20){ System.out.println(stuNum + ">20了,开始唤醒等待集的线程"); condition.signalAll(); } } finally { lock.unlock(); } }
当条件对象调用await()方法时候,当前线程会进入等待集,处于阻塞状态,直到其他线程在同一条件上调用signalAll()方法为止。
原文地址:https://www.cnblogs.com/lovleo/p/11318623.html
时间: 2024-10-13 17:12:26