我正在寻找可以帮助我实现以下模式(伪代码)的机制:
TimeoutLock lock = new TimeoutLock();
while(condition) {
prepare();
lock.enter(); //cannot enter until specified lock timeout elapses
execute();
lock.lockFor(2 minutes);
finish();
}
我需要将要执行的调用限制为不超过某个指定的间隔(例如,两分钟)发生的频率,但如果没有必要,我不想阻止准备或执行。我想知道java是否支持任何锁定机制,该机制在一段时间后"消失"。要求是,当然,即使锁是由锁定它的同一线程输入的,它也不会通过。
我正在考虑涉及信号量和 TimerTask 的解决方案,或者自己计算截止日期并睡了多余的时间,但我想知道是否已经有这样的东西。
谢谢
下面就可以了基本上你有一个 semphore,只有在有许可证的情况下才会让你进入,我这种情况零许可。所以它会尝试 2000 秒,然后最终放弃->
Semaphore s = new Semaphore(0);
Object lock = new Object();
synchronized(lock)
{
execute();
s.tryAcquire(2,TimeUnit.Minutes)
}
Thread.sleep
是一种蹩脚和低级的方式。不推荐
不需要特殊类:
synchronized(lock) {
execute();
Thread.sleep(120 * 1000)
}
正如 Marko 所说,您很可能希望通过将工作交给某种调度程序来做到这一点,而不是阻塞线程。
但是,如果您确实想这样做,我建议您通过在退出关键部分时记录时间戳来做到这一点,并让进入线程等待一段时间。 像这样:
public class TimeoutLock {
private boolean held;
private long available;
public void enter() throws InterruptedException {
acquire();
long pause;
while ((pause = available - System.currentTimeMillis()) > 0L) {
Thread.sleep(pause);
}
}
private synchronized void acquire() throws InterruptedException {
while (held) {
wait();
}
held = true;
}
public synchronized void lockFor(long period) {
held = false;
available = System.currentTimeMillis() + period;
notify();
}
}
你可以使用睡眠
sleep(1000);