使用ReentrantLock的newCondition交替输出数组

Posted java265

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了使用ReentrantLock的newCondition交替输出数组相关的知识,希望对你有一定的参考价值。

今天查看网上的多线程面试题,看见一个这样的题目,下文将具体的实现方式列举如下

下文将使用一种全新的方式,实现数组交替输出元素的方法分享,如下所示:

实现思路:

    借助ReentrantLock,并生成两个线程等待队列

    分别通过中断队列和启动队列的方式,使两个线程交替运行,达到交替运行的目的,如下例所示:

    如:线程A 运行一次后,await,并叫醒线程B

           线程B运行一次后,await,并叫醒线程A

  使用这种交替线程等待的方式,可变相实现线程交替运行

  

package com.java265.other;

import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.ReentrantLock;

public class Test6_1 {

    static Thread t2 = null;
    static Thread t1 = null;

    public static void main(String[] args) throws Exception {

        ReentrantLock rt = new ReentrantLock();
        Condition l1 = rt.newCondition();
        Condition l2 = rt.newCondition();

        t1 = new Thread(() -> {
            rt.lock();
            for (int i = 0; i < 26; i++) {
                char c = (char) (i + (int) \'a\');

                try {
                    l2.signal();
                    l1.await();
                    System.out.print(c);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }

                


            }
            l2.signal();
            rt.unlock();

        });

        t2 = new Thread(() -> {
            rt.lock();
            for (int i = 1; i <= 26; i++) {


                try {
                    l1.signal();
                    l2.await();
                    System.out.print(i + " ");

                } catch (InterruptedException e) {
                    e.printStackTrace();
                }


            }
            l1.signal();
            rt.unlock();
        });


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


    }
}

 

转自:http://java265.com/JavaMianJing/202112/16384957941989.html

以上是关于使用ReentrantLock的newCondition交替输出数组的主要内容,如果未能解决你的问题,请参考以下文章

深入浅出多线程——ReentrantLock

#yyds干货盘点# JUC锁: ReentrantLock详解

Condition源码解析

架构师养成记--14.重入锁ReentrantLock 和 读写锁 ReentrantReadWriteLock

使用Condition

多线程(JDK1.5的新特性互斥锁)(掌握)