您好,欢迎访问代理记账网站
移动应用 微信公众号 联系我们

咨询热线 -

电话 15988168888

联系客服
  • 价格透明
  • 信息保密
  • 进度掌控
  • 售后无忧

Java ReentrantLock使用

近期在看java 多线程的内容,学习了Lock的基本使用方法,作为记录写个博客:
ReentrantLock 集成自Lock接口,实现同步主要是使用lock.lock().方法实现同步块,但是lock锁需要手动释放,使用结束后需要手动调用lock.unlock();
而且要配合try/finally 语句使用,这是阿里巴巴编码规范推荐的写法。
同时lock配合与之配套的Condition类可以实现notify(),wait(),之类的类似功能。上代码

public class MyCondition{
    private Lock lock=new ReentrantLock();
    private Condition condition=lock.newCondition();

    public void awaitTest(){
        lock.lock();
        try {
            System.out.println("awaitTest::"+System.currentTimeMillis());
            condition.await();
            System.out.println("被唤醒+"+System.currentTimeMillis());
        }catch (Exception e){

        }finally {
            lock.unlock();
        }
    }


    public void signalTest(){
        lock.lock();
        try {
            System.out.println("我要唤醒");
            condition.signal();
        }catch (Exception e){

        }finally {
            lock.unlock();
        }
    }

    public static void main(String[] args) {
        MyCondition myCondition=new MyCondition();

        ExecutorService executorService=new ThreadPoolExecutor(5,10,10, TimeUnit.SECONDS,new LinkedBlockingQueue<>());

        Runnable r1=()->{
            myCondition.awaitTest();
        };
        Runnable r2=()->{
            myCondition.signalTest();
        };
        executorService.execute(r1);
        executorService.execute(r2);
        executorService.shutdown();

    }




}

分享:

低价透明

统一报价,无隐形消费

金牌服务

一对一专属顾问7*24小时金牌服务

信息保密

个人信息安全有保障

售后无忧

服务出问题客服经理全程跟进