3

我正在寻找可以帮助我实现以下模式（伪代码）的机制：

TimeoutLock lock = new TimeoutLock();
while(condition) {

    prepare();

    lock.enter(); //cannot enter until specified lock timeout elapses
    execute();
    lock.lockFor(2 minutes);

    finish();
}

我需要将执行的调用限制为不比某个指定的时间间隔（例如，两分钟）更频繁地发生，但如果没有必要，我不想阻止准备或执行。我想知道java是否支持任何锁定机制，一段时间后会“消失”。当然，要求是即使它是由锁定它的同一个线程进入的，锁也不会通过。

我正在考虑涉及 semaphore 和TimerTask的解决方案，或者自己计算截止日期并睡多余的时间，但我想知道这样的东西是否已经可用。

谢谢

4

4 回答 4

1

正如 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();
    }

}
于 2012-11-22T19:02:29.277 回答
1

无需特殊课程：

synchronized(lock) {
   execute();
   Thread.sleep(120 * 1000)
}
于 2012-11-22T18:24:08.240 回答
1

下面将基本上你有一个信号，它只会让你访问如果有可用的许可证，我这种情况下是零许可证。所以它会在最终放弃之前尝试 2000 秒 ->

Semaphore s = new Semaphore(0);
Object lock = new Object();
 synchronized(lock)
{
execute();
s.tryAcquire(2,TimeUnit.Minutes)
}

Thread.sleep是一种蹩脚和低级的做法。不建议

于 2012-11-22T18:28:32.773 回答
0

你可以使用睡眠

sleep(1000);
于 2012-11-22T18:15:48.127 回答