钉钉过期任务有3个可是打开只显示2个
Posted
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了钉钉过期任务有3个可是打开只显示2个相关的知识,希望对你有一定的参考价值。
参考技术A (1)如果其他应用正常,或者企业其他人打开应用没问题,可能是缓存问题引起,请清除下缓存(2)参数redirect_uri的值没有做url编码
(3)redirect_uri的域名和微应用的域名不一致
DelayQueue 意外行为。 DrainTo 从队列中只删除 1 个过期项目
【中文标题】DelayQueue 意外行为。 DrainTo 从队列中只删除 1 个过期项目【英文标题】:DelayQueue unexpected behavior. DrainTo deletes from the queue only 1 expired item 【发布时间】:2017-07-11 10:45:07 【问题描述】:我想遍历我的延迟队列中未过期的元素。 Transaction 类实现了Delayed,并有一个字段timestamp,表示事务在UTC 发起时的时间戳(不是当前时间戳)
public class Transaction implements Delayed
private final Double amount;
private final Long timestamp; //timestamp of a time when the item was created and send here
public Transaction(double amount, long timestamp)
this.amount = amount;
this.timestamp = timestamp;
@Override
public long getDelay(TimeUnit unit)
long delay = unit.convert(ONEMINUTE - (System.currentTimeMillis() - timestamp), TimeUnit.MILLISECONDS);
return delay;
@Override
public int compareTo(Delayed delayed)
if (delayed == this)
return 0;
if (delayed instanceof Transaction)
return 0;
long diff = (getDelay(TimeUnit.MILLISECONDS) - delayed.getDelay(TimeUnit.MILLISECONDS));
return ((diff == 0) ? 0 : ((diff < 0) ? -1 : 1));
@Override
public int hashCode()
final int prime = 31;
int result = 1;
result = prime * result + timestamp.hashCode();
return result;
@Override
public boolean equals( Object obj )
if( this == obj )
return true;
if( obj == null )
return false;
if( !( obj instanceof Transaction ) )
return false;
final Transaction other = ( Transaction )obj;
return timestamp.equals(other.timestamp);
如果新到来的事务小于 1 分钟,则下面的 TransactionManager 类将传入事务添加到队列中。 在 getStatistics 上,应该从队列中删除旧事务,并且队列应该只包含小于 1 分钟的事务
public class TransactionManager
private DelayQueue<Transaction> transactions;
public TransactionManager()
transactions = new DelayQueue<>();
System.setProperty("user.timezone", "UTC");
public Object createTransaction(String json)
JSONObject jsonObject = null;
try
jsonObject = JsonValidator.validateTransactionJson(json);
catch (Exception ex)
return new ResponseEntity(HttpStatus.UNPROCESSABLE_ENTITY);
long delay = System.currentTimeMillis() - ((Long) jsonObject.get(TIMESTAMP));
if (delay > ONEMINUTE)
return new ResponseEntity(HttpStatus.NO_CONTENT);
transactions.add(new Transaction((Double) jsonObject.get(AMOUNT), (Long) jsonObject.get(TIMESTAMP)));
return new ResponseEntity(HttpStatus.OK);
public long getStatistics()
List<Transaction> tempForCleaning = new ArrayList<>();
transactions.drainTo(tempForCleaning);
tempForCleaning.clear();
StatisticJSON statistics = new StatisticJSON();
transactions.stream().forEach(transaction ->
statistics.setCount(statistics.getCount() + 1);
);
return statistics.getCount();
在这个测试中,我创建了 5 个时间为 40 秒之前的事务,以及 3 个时间为 10 秒之前的事务。 所以在等待 45 秒后,前 5 个应该被排空,队列应该只包含 3 个事务,但是,drainTo 方法只删除了 1 个旧事务。
@Test
public void test()
DateTime dateTime = new DateTime(DateTimeZone.UTC);
long fortyMilliSecondsAgo = dateTime.minusSeconds(40).getMillis();
long twentyMilliSecondsAgo = dateTime.minusSeconds(10).getMillis();
for (int i = 0; i < 5; i++)
createTransaction(fortyMilliSecondsAgo);
for (int i = 0; i < 3; i++)
createTransaction(twentyMilliSecondsAgo);
Assert.assertTrue(transactionManager.getStatistics() == 8);
try
TimeUnit.SECONDS.sleep(45);
System.out.println("\n\n\n");
Assert.assertTrue(transactionManager.getStatistics() == 3);
catch (InterruptedException e)
e.printStackTrace();
private void createTransaction(long timestamp)
transactionManager.createTransaction("\"amount\":100.0,\"timestamp\":" + timestamp + "");
我遗漏了一些东西,为什么 drainTo 只删除一个过期项目,即使还剩下 4 个,但无法捕捉到哪里......
【问题讨论】:
【参考方案1】:if (delayed instanceof Transaction) return 0;
看起来不正确 - 如果您希望 compareTo
与 getDelay()
保持一致,您可能应该删除该位。所以你的方法应该看起来像这样(使用静态导入):
public int compareTo(Delayed delayed)
return delayed == this
? 0
: Long.compare(getDelay(MILLISECONDS), delayed.getDelay(MILLISECONDS));
【讨论】:
谢谢,你说的很对,那部分我看不到 :)以上是关于钉钉过期任务有3个可是打开只显示2个的主要内容,如果未能解决你的问题,请参考以下文章