所有,我有一个API调用被许多线程调用。唯一的问题是延迟下注。线程应该至少1秒。我意识到 - 无论是同步块 - 如果一个线程在t1时刻调用api,则所有其他线程等待1秒,然后所有其他线程在t1 + 1秒调用api。这不是我想要的,所以我把整个等待块放在同步块中,只要一个线程正在等待所有其他线程块。创建线程之间的延迟
This Works;不过,我认为它不是最有效的方法。
任何建议,非常感谢。
private static volatile AtomicLong lastAPICall = new AtomicLong();
private void callAPI() {
// 1 sec plus a little extra
final long oneMS = 1 * 1000 + 100;
long lastCall = 0;
long timeDiff = 0;
synchronized (lastAPICall) {
timeDiff = System.currentTimeMillis() - lastAPICall.get();
lastCall = lastAPICall.getAndSet(System.currentTimeMillis());
}
}
if (System.currentTimeMillis() - lastCall < oneMS) {
synchronized (lastAPICall) {
try {
long sleep = oneMS - timeDiff;
Thread.sleep(oneMS - timeDiff);
} catch (InterruptedException ignore) {}
finally {
lastAPICall.set(System.currentTimeMillis());
log.info("Thread: " + Thread.currentThread().getId() + " calling the api at this time: " + System.currentTimeMillis());
}
}
}
try {
// API CALL
}
catch (IOException t){
throw t;
} finally {
synchronized (lastAPICall) {
lastAPICall.set(System.currentTimeMillis());
}
}
// Log files for running the code with 4 threads
Thread: 35 calling the api at this time: 1456182353694
Thread: 34 calling the api at this time: 1456182354795
Thread: 37 calling the api at this time: 1456182355905
Thread: 36 calling the api at this time: 1456182357003
您希望每个线程在前一个线程开始其调用之后或在前一个线程结束其调用之后等待一秒钟吗? –
我希望每个线程在前一个线程开始呼叫后等待一秒钟。 – blueSky
第一个通话是否已经完成并不重要。 – blueSky