2回答
问题在哪里？ReentrantLock没有显示预期的结果。两个线程在同一时间执行，而不是等待一个线程。
class MyThread2 extends Thread{
String name;
ReentrantLock reentrantLock = new ReentrantLock();
MyThread2(String name){
this.name = name;
}
public void run(){
do {
try {
if (reentrantL
浏览 1提问于2018-04-28得票数 0
回答已采纳
3回答
我有一个web应用程序，它同时提供大量的请求。在应用程序的一个API方法中，我有一个方法- methodA()。在这个方法中，我调用了另一个方法- doSomething()。在我的场景中，我希望对methodA()的第一个调用将在一个单独的线程中运行doSomething()方法，但此时，如果调用了另一个对methodA()的调用，则不要运行doSomething()方法(因为它仍然由另一个线程运行)，只需继续使用methodA()的其余部分。
methodA() {
.
.
doSomething() // In a new thread
.
.
}
我考虑过使用原子布尔值作为标
浏览 0提问于2019-06-23得票数 4
回答已采纳
1回答
假设我有一个具有多个线程的服务器，该服务器共享对数据实例的引用。快如，
edit1:更新以提高可读性
public void main() {
Data data = new Data();
ReentrantLock rl = new ReentrantLock(true);
ReadThread t1 = new ReadThread(data, rl);
UploadThread t2 = new UploadThread(data, rl);
t1.start(); t2.start();
}
class ReadThread extends Thread {
privat
浏览 1提问于2016-11-29得票数 4
回答已采纳
这是关于重入锁中的tryLock()方法。我正在运行下面的示例代码。我知道这段代码会陷入死锁。
import java.util.concurrent.locks.ReentrantLock;
public class TestMain {
public static void main(String[] args) {
ReentrantLock rl=new ReentrantLock();
S t1=new S(rl);
S t2=new S(rl);
Thread t=new Thread(t1);
浏览 4提问于2017-09-06得票数 1
回答已采纳
1回答
我目前正在考虑实现一个会话管理器java类，它提供按需读取和刷新会话令牌的功能。如果正在刷新会话令牌(即从服务器获取)，则会话令牌读取器应该阻塞，直到刷新完成为止。类似地，刷新请求将被阻塞，直到任何正在进行的读取都未完成为止。由于与会话令牌刷新请求相比，会话令牌读取请求非常频繁，所以我决定使用ReentrantReadWriteLock实现读取和刷新之间的同步。以下是它的外观：
String refreshToken() {
try{
if (readWriteLock.writeLock().trylock()) {
浏览 4提问于2015-10-07得票数 2
回答已采纳
我是Java的新手，尝试着用实现来学习Java概念。这里使用ReentrantLock类的原因是为了理解锁。
我正在生成3个线程，在这些线程中，我只是增加了一个全局计数器。我使用锁保护计数器被其他线程覆盖。
import java.util.concurrent.locks.ReentrantLock;
class ReentryHandledSingleThread extends Thread
{
static long counter = 0;
private int myId;
private final ReentrantLock myLock = ne
浏览 1提问于2014-10-07得票数 1
回答已采纳
2回答
锁定方法的名称
、、、
在异步代码和多线程代码中，我都见过几次这种方法。计数器用于跟踪异步行为或线程行为--每当启动新操作时，计数器就会递增。当它完成时，计数器就会减少。
当这种情况发生时，只有当计数器为零时，另一个进程才能继续进行。但是，原始进程可以多次重新获取锁，而不需要死锁。
这对于处理在移动到另一个工作流之前需要解决的用户操作特别有用。
这种锁定方法有名字吗？
浏览 0提问于2019-09-10得票数 2
回答已采纳
为了了解多线程是如何工作的，我使用Queue和ReentrantLock来模拟生产者和消费者问题。我的生产者线程正在向队列中添加数据，但是使用者没有删除。我不知道我是否正确地执行了它。据我所知，这已被要求，但他们没有帮助。
包并发；
import java.util.Queue;
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.locks.Condition;
import java.util.concur
浏览 5提问于2016-10-13得票数 0
回答已采纳
如果一个线程获得了一个锁，我希望其他线程跳过获取锁的尝试，只需等待锁被释放才能继续执行。我不希望其他线程一旦释放锁就获得它。
我已经读了很多关于这个问题的文章，但还是很困惑。
请参阅下面的通用代码片段：
private final ReentrantLock reentrantLock = new ReentrantLock();
public void aCoolMethod(){
if (reentrantLock.tryLock() == true){
try {
doSomething();
} finally {
浏览 0提问于2019-05-16得票数 1
回答已采纳
2回答
按值锁定
、
我有一个多线程Java应用程序，它附加到动态生成的路径(大数字--超过100k)中的各种文件。我想防止并发写入。因为这是JVM中的争用，所以我不能使用FileLock。
相反，我一直在尝试对Path对象进行同步，如下所示(PathLocker是一个单例)。
public class PathLocker {
private final ConcurrentMap<Path, ReentrantLock> pathLockMap = new ConcurrentHashMap<>();
public void lock(Path path) {
浏览 0提问于2015-11-02得票数 6
1回答
我有三个对象，它们是实现Runnable接口的两个不同类的实例。其中一个对象更改了其他两个对象的计数器，但我希望确保整个更新操作不会被其他线程中断(即，我想对我的临界区使用锁)。 在下面的代码中(这是实际代码的说明，而不是代码本身)，我希望确保临界区中的代码在没有任何中断的情况下执行。 我的一个想法是在Worker类中定义一个二进制信号量m，并在每个涉及value和operations的操作周围加上m.acquire()，然后是m.release()。但是，在“Runner”类中，我有一个对incrementValue()的调用，如果我用acquire()/release()调用包围CS，而
浏览 10提问于2020-05-01得票数 1
回答已采纳
我正在尝试使多个使用者线程侦听一个生产者线程，直到生产者有要发布的东西。我认为可以工作的代码“丢失”了被放入共享类和从共享类中取出的锁。
在控制器类中，我使用Server = new ()启动运行的线程；
Thread serverThread = new Thread(server,"Server");
serverThread.start();
Consumer consumer = new Consumer();
Thread consumerThread;
for (int i =0;i<6;i++){
浏览 4提问于2014-01-03得票数 2
回答已采纳
1回答
在我们的web应用程序中，我们有下面的代码片段，这些代码片段是用一个按钮调用的：
if (!isResponsibleSet(request))
{
edit(request, [("responsibleUser"):(user)];
}
请求是我们正在编辑的对象
用户是即将对请求负责的用户。
问题是，有时只有一个用户同时单击同一个按钮。
不幸的是，在上面描述的场景中发生了以下情况：
用户1单击按钮
用户2单击按钮
if语句计算用户1的真
if语句计算用户2的真
用户1编辑请求并成为负责人。
用户2编辑请求并成为责任方。
if语句计算用
浏览 2提问于2020-11-02得票数 4
回答已采纳
我有一个Map<String, Queue<?>>，每次我必须放置一对(键，值)，我需要得到与该键关联的非线程安全队列，并向它添加一个值(如果存在键)。因为我需要更新现有值(队列)，所以我认为最好的方法是使用ReentrantLock ( Java <1.5中的同步块或同步(对象))，而不是使用ConcurrentHashMap。
这是正确的，还是我可以使用ConcurrentHashMap而不是HashMap + Lock？我认为ConcurrentHashMap在get操作中更有效，但我不知道这里是否是正确的解决方案。
private static R
浏览 2提问于2015-05-11得票数 1
回答已采纳
2回答
我正在浏览线程，我读到notify()方法用于向同一对象的等待池中等待的一个且只有一个线程发送信号。方法notifyAll()的工作方式与notify()相同，只是它将信号发送到等待Object的所有线程。
现在我的问题是，假设我有5个线程和一个主线程，那么最初主线程启动，然后其他5个线程启动。现在我只想向第三个线程发送通知。既然我在这里只向第三个线程发送通知，使用notify()怎么可能呢？请给我建议。
浏览 1提问于2012-04-15得票数 1
2回答
春调度同步法饥饿
、、、、
假设我有一个调度程序
@Component
public class Scheduler{
private static int counter = 0;
private synchronized void countIt(){
counter++;
}
@Scheduled(fixedDelay = 3000)
public void job1(){
countIt();
}
@Scheduled(fixedDelay = 6000)
public void job2(){
浏览 3提问于2016-10-14得票数 1
回答已采纳
2回答
我需要使用挥发性吗？
、、、
考虑以下代码：
public class MyDataStructure {
int size;
final ReentrantLock lock = new ReentrantLock();
public void update() {
lock.lock();
try {
// do coll stuff
size++;
} finally {
lock.unlock();
}
}
public int siz
浏览 10提问于2022-09-19得票数 2
回答已采纳
2回答
我需要提供对类的方法的相互访问，这样一个线程就可以在方法中执行代码。我已经尝试了下面的解决方案，但是我不明白为什么每次变量'locked‘的值都是假的。
public class MyCommand extends BaseCommand {
private static boolean locked=false;
@Override
public boolean execute() throws Exception {
synchronized(MyCommand.class){
while (locked){
wait
浏览 4提问于2015-01-23得票数 0
回答已采纳
? 上面是OCP 7 java se书中的屏幕打印。791页。 我的问题是，如果每次都在一个方法中创建一个新的ReentrantLock对象并将其锁定，那么如何阻止lock和unlock之间的两个线程运行代码块呢？这两个线程不是各自创建一个ReentrantLock对象并锁定它吗？我可以想象如果lock对象是一个实例变量，只实例化一次，并且永远不会改变，那么这将是如何工作的。(最好是final)。 我是不是误解了什么？ 我已经问过this了，没有得到明确的答案。
浏览 26提问于2019-03-22得票数 2
回答已采纳
你能帮我一下吗？当我想要确保只有一个线程修改队列时，这对于BlockingQueue是必要的吗？：
BlockingQueue队列=新的ArrayBlockingQueue(1024)；
Collections=Collections.synchronizedCollection(queue)；<-这是必要的吗？
浏览 2提问于2015-02-06得票数 2
我有一个带有静态变量的类，多个线程将有这个类的实例。
我关注的静态变量是一个Thread，它将从队列中弹出一条消息并以电子邮件的形式发送，直到队列为空。每次将消息添加到队列中时，我都会检查线程是否处于活动状态。如果没有，我会重新启动它。
if (mailThread == null)
{
mailThread = new Thread(mailSender);
mailThread.start();
}
else if (!mailThread.isAlive())
{
mailThread = new Thread(mailSender);
mailThrea
浏览 5提问于2016-02-21得票数 3
回答已采纳
1回答
死锁获取锁
、、
我有一个死锁的线程转储，我找不到原因。在第一次检查时，看起来有些客户端代码只是无法获得ReentrantLock上的锁，该锁是MyClass拥有的。
"qtp1450652220-77" Id=77 WAITING on java.util.concurrent.locks.ReentrantLock$NonfairSync@1e319fef owned by "pool-2-thread-2" Id=1651
at sun.misc.Unsafe.park(Native Method)
- waiting on java.util.concu
浏览 1提问于2018-04-09得票数 0
我有一个应用程序，在一个特定的组件中不断获得ANR，但我不能找出是什么在占用cpu时间。最近我得到了两种ANR，一种是本地的，一种是等待。
DALVIK THREADS:
"main" prio=5 tid=1 NATIVE
| group="main" sCount=1 dsCount=0 s=N obj=0x4001d8c0 self=0xccc8
| sysTid=10569 nice=0 sched=0/0 cgrp=default handle=-1345017816
| schedstat=( 9041503981 6690216078
浏览 4提问于2011-03-13得票数 3
回答已采纳
1回答
创建一个同步多线程系统，以确定三个文本文件中所有整数或分数的总数。如果流被阻塞，它必须将其名称显示为“锁定”。为什么只计算一个文件(带锁的线程)？程序显示什么:线程-0锁定！线程-2锁定！123.321 322099，只用于一个文件
import java.io.*;
import java.util.*;
import java.util.concurrent.locks.*;
public class Dispatcher {
public static void main(String[] args) throws Inte
浏览 3提问于2021-12-14得票数 0
回答已采纳
1回答
在Java中，我们可以通过使用Lock接口和ReentrantLock类实现公平性，如下所示：
Lock lock=new ReentrantLock(true);
一旦我们实现了公平性，那么在多个线程等待访问锁的情况下，等待时间最长的线程被赋予访问锁的权限。
有谁能提供JVM如何让线程等待很长时间的详细信息，即JVM是如何实现公平性的。
浏览 5提问于2016-04-24得票数 3
回答已采纳
我想知道是否有人能帮我。我对并发编程很陌生，我有下面的代码，它有时会给我一个IllegalMonitorStateException，因为目前没有锁的线程正在试图解锁。
我在OTN论坛上被告知，为了防止这种情况和死锁的发生，我应该确保首先锁定最低的索引，但我不知道如何做到这一点。你们谁能帮我指出正确的方向吗？
非常感谢。
import java.util.concurrent.locks.*;
class ShuffleBase {
ReentrantLock [] locker;
int [] data;
浏览 2提问于2010-12-29得票数 0
例如，我正在尝试理解signalAll()如何不破坏临界区
//Some Class Here is Trying to use an resource which is to to initialized in an seperate thread
ReentrantLock lock=new ReentrantLock();
Condition wait=lock.newCondition();
Resource res=new Resource(lock); //An Important Resource Which Should Be Accessed Only By One Th
浏览 1提问于2020-08-23得票数 0
一个线程调用plus1，second- plus2。会是第一个字段更改吗？或者它不能用于调用第二次lock()的线程？
如果plus2不调用lock()，他将使用什么值？
public class Test {
private final ReentrantLock lock = new ReentrantLock();
private int first;
public void plus1() {
lock.lock();
try {
first++;
} finally {
lock.unlock();
}
}
pub
浏览 0提问于2011-08-11得票数 1
我正在尝试使用ReentrantLock实现阻塞FIFO。除了抛出IllegalMonitorStateException之外，一切都很好。当我们试图释放未被线程锁定的资源时，可能会发生此错误。但我找不到为什么这个错误出现在这里。
package edu.utdallas.blockingFIFO;
import java.util.concurrent.locks.Condition;
import java.util.concurrent.locks.Lock;
import java.util.concurrent.locks.ReentrantLock;
import edu.ut
浏览 2提问于2016-10-27得票数 1
回答已采纳
我在两个不同的线程之间使用LinkedBlockingQueue。一个线程通过add添加数据，而另一个线程通过take接收数据。
我的问题是，我是否需要同步对add和take的访问。LinkedBlockingQueue的insert和remove方法线程安全吗？
浏览 4提问于2010-04-23得票数 60
回答已采纳
1回答
所以我有一个非线程安全API (一些供应商软件)，我们目前使用的方式是每个线程一个对象。也就是说，每一个线程都有：
Foo instance = new Foo();
然而，这似乎不适用于这个特定的库。它的一些非线程安全的部分看起来仍然是对头的，所以我假设这个库中包含一些静态值。在我们知道存在问题的几个点上，我们目前正在使用ReentrantLock在需要时锁定类。也就是。
public class Bar {
protected static final ReentrantLock lock = new ReentrantLock();
public void proces
浏览 1提问于2016-05-25得票数 2
回答已采纳
如果我有这个代码：
public class PrLock {
private Lock lock1= new ReentrantLock();
private Lock lock2= new ReentrantLock();
private int num=0;
public void addLock1(){
lock1.lock();
try {
num++;
System.out.println(Thread.currentThread().getName()+" N
浏览 0提问于2015-05-14得票数 0
2回答
在Java线程转储中，可以看到堆栈跟踪中提到的锁。
似乎有三种信息：
1：
- locked <0x00002aab329f7fa0> (a java.io.BufferedInputStream)
2：
- waiting to lock <0x00002aaaf4ff6fa0> (a org.alfresco.repo.lock.LockServiceImpl)
3：
- parking to wait for <0x00002aaafbf70bb8> (a java.util.concurrent.SynchronousQueue$TransferS
浏览 3提问于2012-07-05得票数 50
回答已采纳
众所周知，HotSpot VM有偏置锁、自旋锁、轻量级锁、重量级锁等，ReentrantLock是由AbstractQueuedSynchronizer(AQS)实现的。那么ReentrantLock是JVM中的一个轻量级锁吗？
浏览 1提问于2020-04-04得票数 3
回答已采纳
1回答
可重入锁能与同步块一起工作吗？
、、、、
我在Java应用程序中有一个数据传输对象(DTO)，它是从多个不同的线程跨应用程序读取和写入的。到目前为止，我已经能够使用synchronized(dto.class)进行同步。现在有一个实例需要将锁保存在调用它的方法之外，因此我将使用ReentrantLock()类。
是否有一种线程安全的方法在一个实例中使用可重入锁来实现其功能，同时保持同步块与代码的其余部分相同？或者，是否使用重入锁意味着所有相关的同步块都必须删除？
浏览 2提问于2022-10-10得票数 0
3回答
我必须加载文件并打印其中的数据，但是所有线程都是并行运行的，所以几秒钟后只会显示最后一个文件中的数据。总共有七个文件，我正在循环加载它们。
下面是我的代码：
public class thread extends Thread {
private static final String String = null;
static String file="Lab5File";
static String output="test2.dat";
static ArrayList<Thread> threadL
浏览 1提问于2015-03-18得票数 0
我有实现Runnable的类
public class MyRunnable implements Runnable {
private long RID = <SOME_LONG_ID_VALUE>;
public long getRID() { return this.RID; }
public void run {
System.out.println("HAI!");
}
}
有没有办法通过RID字段在ThreadPoolExecutor中“路由”任务(我的意思是，如果线程N 3运行RID = 1，那么RID
浏览 0提问于2013-07-23得票数 1
3回答
这个问题类似于我刚刚发布的另一个问题(并得到了答复)。因此，问题的陈述是一样的：“我正在编写一个演示程序来解释如何在Java中调节一群线程的并发性，但结果并不像我预期的那样。”这一次我想使用锁，这是代码：
public class Parcount extends Thread {
private static int N=1000;
private static int x=0;
private final ReentrantLock l = new ReentrantLock();
public static void main(String[] args)
浏览 2提问于2014-04-07得票数 0
回答已采纳
1回答
我搜索了很多，但与'ReentrantLock'和正常'synchronized'的过程相混淆。
例如(1)：
Object obj = new Object();
synchronized(obj){
//lock is guaranteed to be acquired
}
示例(2)
Lock lock = new ReentrantLock();
lock.lock(); //problem here
try{
//dostuff
}
finally{
lock.unlock();
}
我的问题是：
例如，1：它保证使用同步关键字获取对象的锁。
但
浏览 1提问于2015-11-14得票数 0
回答已采纳
我想知道ReentrantLock和ReentrantReadWriteLock在逻辑上有什么不同。换句话说，是否存在只需要一个没有读/写锁的锁的情况，反之亦然，读/写锁和只有一个锁是不够的？ 考虑以下仅使用锁的主要示例： public class Counter {
private int counter = 0;
private ReentrantLock lock = new ReentrantLock(true);
public void increment() {
lock.lock();
counter += 1;
lock.unlock(
浏览 18提问于2019-09-05得票数 4
1回答
我使用dumpAllThreads(true, true)使用ThreadMXBean来报告线程列表
ThreadMXBean bean = ManagementFactory.getThreadMXBean();
for (ThreadInfo info : bean.dumpAllThreads(true, true)) {
writer.append(ThreadInfos.toStringFull(info));
}
但是，转储中的一些线程似乎并不存在，更糟糕的是，它们似乎拥有监视器！：
"pool-24-thread-16" Id=99 WAITING on
浏览 1提问于2016-11-21得票数 1
在CompletableFuture世界之前，如果我想锁定一个变量，我可以这样做：
private ReentrantLock myLock = new ReentrantLock();
private List<UUID> myLockableList = new ArrayList<>();
public void doStuff()
{
try
{
myLock.lock();
myLockableList.clear();
}
finally
{
if (myLock.
浏览 1提问于2020-01-14得票数 0
回答已采纳
1回答
请建议解决以下问题的最佳方法： 我有一个java类，如下所示： @Service
public class ServiceAImpl {
private final Set<String> someSet = new HashSet<>();
private final List<Record> someList = new ArrayList<>();
private final Map<String, String> someMap = new HashMap<>();
//Load
浏览 16提问于2020-12-02得票数 0
对于一个单独的非争用锁获取，ReentrantLock对synchronized的性能如何？
假设你打算实现一个两个锁的类(这意味着你需要两个不同的锁，而synchronized是不够的，就像在LinkedBlockingQueue中一样)，其中put和take锁的获取是由thread1和Thread2 (always)完成的，这意味着锁是无争用的，线程局部性的原则出现了，ReentrantLock对synchronized的性能如何(这将需要队列的完全锁定)？
浏览 3提问于2012-07-28得票数 3
回答已采纳
4回答
对于我的类，我有以下的锁定机制。当我运行这个程序时，一个线程不断地获取和重新获取锁，而不给任何其他线程获取锁的机会，从而导致饥饿。我如何重构我的锁定机制，使得一旦一个线程放弃了一个锁，另一个线程就获得了它？我希望看到其他线程获得锁，而不必等到拥有锁的线程停止运行。
private final ReentrantLock lock = new ReentrantLock();
private final Condition condition = lock.newCondition();
private final Map<Integer, Long> locksMap
浏览 1提问于2012-08-18得票数 4
回答已采纳
3回答
我试图通过阻止异步尝试使用RentrantLock修改实体的给定实例(由键标识)来实现类，以在我的java应用程序中强制并发。目标是阻止/队列多次并发尝试修改对象的给定实例，直到以前的线程完成为止。类以一种通用的方式实现了这一点，允许任何代码块获得一个锁并释放它(与RentrantLock语义相同)，添加的实用工具是只阻塞试图修改对象的同一个实例的线程(如键所标识的)，而不是阻塞进入代码块的所有线程。
这个类提供了一个简单的构造，允许只为一个实体的一个实例同步代码块。例如，如果我希望为所有来自id 33的用户的线程同步代码块，但我不希望任何其他用户的线程被服务于用户33的线程阻塞。
类按以下方
浏览 7提问于2012-05-03得票数 3
回答已采纳
1回答
在我的应用程序中，我们在工作线程中为大约2000条记录做applyBatch。
同时，如果我旋转屏幕，我将得到黑色屏幕。
" main@6280“java.util.concurrent.locks.LockSupport.park(LockSupport.java: prio=5 java.lang.Thread.State:等待街区main@6280 at java.lang.Object.wait(Object.java:-1) at java.lang.Thread.parkFor$(Thread.java:1220) - locked <0x18c5> (a j
浏览 4提问于2016-06-13得票数 1
我注意到下面的代码块：
final Lock s = new ReentrantLock();
for(int i = 0 ; i < 1000 ; i++)
{
s.lock();
System.out.println(i+" :" +s.tryLock()+" ");
}
打印：
0 :true
1 :true
2 :true
3 :true
...
这很奇怪--我认为连续的锁会失败，因为s永远不会解锁。
这里有防晒霜吗？
浏览 0提问于2012-03-08得票数 4
2回答
线程、锁和条件的状态
、、、、
在Java中，如果一个线程t2试图从同步(目前由另一个线程t1使用)获得锁，那么t2将从runnable切换到阻塞。对，是这样?那ReentrantLock呢？
如果线程t1使用锁完成，那么t2会自动切换回runnable，还是需要使用notifyAll()？在没有条件的情况下使用ReentrantLock会怎么样？如果没有使用条件，如何通知线程t2它应该切换回可运行状态？在没有条件的情况下使用重入锁是明智的，甚至是可能的吗？
如果这个问题已经回答了(我找不到)，如果你能把它和我联系起来，我将不胜感激。
浏览 1提问于2017-01-03得票数 2
回答已采纳
3回答
我对断言lock.getHoldCount() == 0的方法感到困惑；下面的示例来自Java，它写的是Returns: the number of holds on this lock by the current thread, or zero if this lock is not held by the current thread，我不太理解。
class X {
ReentrantLock lock = new ReentrantLock();
// ...
public void m() {
assert lock.getHoldCo
浏览 8提问于2014-10-29得票数 0
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
腾讯会议
实时音视频活动推荐
腾讯云开发者
