如何通过ReentrantLock的newCondition实现交替输出数组元素？

本文共计520个文字，预计阅读时间需要3分钟。

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

实现思路：使用Reen

具体实现方法：pythonimport reimport threading

def replace_elements(text): pattern=r'\b(\w+)\b' def replacer(match): return 'REPLACED' return re.sub(pattern, replacer, text)

def process_text(text): result=replace_elements(text) print(result)

if __name__=='__main__': text=Hello, this is a sample text with some words. thread=threading.Thread(target=process_text, args=(text,)) thread.start() thread.join()

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

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

实现思路:

借助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();


}
}

​​转自：java265.com/JavaMianJing/202112/16384957941989.html​​