回答情况：
提问时间：
问题标签：
我有一个调用Semaphore.tryAcquire(timeout, timeunit)函数的函数。现在我想中断这个tryAcquire函数，这样调用者函数就会抛出一些异常。我的代码思路如下： semaphore.tryAcquire(timeout, timeunit);
浏览 0提问于2016-05-01得票数 2
semA.tryAcquire()) { } catch(InterruptedException据我所知，tryAcquire ()应该立即返回true或false，而不是延迟响应。我们如何解决这个问题呢？
浏览 4修改于2022-07-05得票数 -1
回答已采纳
如果不公平的信号量许可不能立即获得，那么tryAcquire(long timeout, TimeUnit unit)块会一直到许可可用(即屈服执行)，还是会一直旋转到许可可用为止？
浏览 2修改于2012-10-03得票数 1
我正在寻找python替代Java的tryAcquire信号量函数。我发现这个函数是在python版本3及更高版本中添加的。我使用的是python版本2.6.5。我有别的选择吗？我这里只有semaphore.acquire(blocking=False)，这是我用Java编写的代码-(信号量释放是在另一个线程中完成的，我没有包含它的代码)
if(Sem.tryAcquire(30
浏览 1提问于2013-06-17得票数 1
信号量中的tryAcquire(long timeout, TimeUnit unit)方法不会立即返回。线程不会被阻塞，并且允许所有线程获取该信号量，即使其中一个线程正在获取该信号量。try {
TimeUnit.MILLISECONDS)) {
updateResource(
浏览 1修改于2019-10-13得票数 0
() throws Exception{ _log.info("Acquired one " + lt.tryAcquire());}: 08 16:22:10 PST.INFO1*RateLimiterTst~() throws Exception{
RateLimiter lt = RateLimit
浏览 1修改于2015-12-09得票数 3
我一直在学习java中的并发性，在研究java信号量时遇到了一个问题。我有多个线程试图获取多个锁中的一个，以访问受信号量保护的临界区，并希望所有未能获取锁的线程执行特定任务，然后尝试重新获取锁。每次获取失败时，我都希望线程完成我所做的等待任务，当它完成后，再试一次。重复此步骤，直到获得。查看java信号量类的java文档，所有的acquire方法似乎都以某种方式进行了阻塞。我怎样才能实现我想要的？
浏览 44提问于2020-02-18得票数 1
回答已采纳
我完全看不出为什么这不是一个每次调用的选项。信号量可能会在不同的代码路径中被关闭(主进程检查/工作进程从队列中抓取/ ...)具有不同的公平性要求。也许在一种情况下，我们希望公平地检查进度，而在另一种情况下，我们希望相同的少数工作人员工作，如果只有运行的工作人员有足够的工作，以优化L1缓存命中等。)
浏览 0提问于2015-06-06得票数 3
2回答
tryAcquire(arg))} if (getState() == 0 && compareAndSetState(0, acquires理论上，这个tryAcquire可以简单地返回false，对吗？
我认为这是一次潜在的重试，因为
浏览 3修改于2021-01-29得票数 2
回答已采纳
CACHE_SIZE) .build();
cache.put(key, rateLimiter); // <- This executes.. return rateLimiter.tryAcquire此外，我在return rateLimiter.
浏览 0修改于2020-02-23得票数 0
在我的Java程序中，我需要一个单许可证信号量对象，其中有一个额外的获取方法，如下所示：它的行为如下:如果之前没有遇到id，那么记住它，然后做java.util.concurrent.Semaphoreprivate final Set<Integer> favoured = new ConcurrentSkipListSet<Integer>();
return semaphore.t
浏览 0修改于2011-03-05得票数 11
2回答
boolean a3=false; try{ a1=true; if(res[3].tryAcquire()==true)){
浏览 0修改于2013-04-04得票数 2
回答已采纳
rl = RateLimiter.create(2); System.out.println(rl.tryAcquire()); System.out.println(rl.tryAcquire());
}
浏览 5提问于2021-04-07得票数 0
回答已采纳
Semaphore (这个类可以看作是一个Semaphore，只有1许可，不允许许可数量变为负数)：acquire(long timeout, TimeUnit timeUnit)tryAcquire(long timeout, TimeUnit timeUnit)客户端代码中的使用模式： * @return null, or the combination for releasing the lock
浏览 0修改于2022-11-15得票数 3
我的想法是使用LinkedList方法实现tryAcquire()，如果结果为false，则在列表底部添加currentThread。由于无法使用我搜索的tryAcquire()方法，我注意到了这个构造。
浏览 0修改于2018-01-23得票数 5
回答已采纳
我相信以下代码片段是相关的：protected final boolean tryAcquire(int acquires) {false; final Node p = node.predecessor();
if (p == head && tryAcquire
浏览 0修改于2013-03-24得票数 1
回答已采纳
this.maxPermits = permits; }
return semaphore.tryAcquire();if (rateLimiter.tryAcquire())
浏览 19提问于2021-09-14得票数 0
回答已采纳
个可用的信号量许可证，如下所示： if(semaphore.tryAcquire在重新启动时，上面的tryAcquire()方法返回false。这不是我所期望的。我希望客户端节点重新获取许可证，该许可证是在客户端离开拓扑时释放的。
浏览 0提问于2017-09-22得票数 2
i = 1; i <= noOfNodes; i++) if( mutex.tryAcquirepermutation generated: "+permutation if(mutex.tryAcquire
浏览 1提问于2017-12-22得票数 0
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号