钉钉过期任务有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; 

看起来不正确 - 如果您希望 compareTogetDelay() 保持一致,您可能应该删除该位。所以你的方法应该看起来像这样(使用静态导入):

public int compareTo(Delayed delayed) 
  return delayed == this
    ? 0
    : Long.compare(getDelay(MILLISECONDS), delayed.getDelay(MILLISECONDS));

【讨论】:

谢谢,你说的很对,那部分我看不到 :)

以上是关于钉钉过期任务有3个可是打开只显示2个的主要内容,如果未能解决你的问题,请参考以下文章

我点开钉钉家校本显示没有或没有权限可是我同事都有?

苹果手机钉钉打开工作台没有权限

钉钉号怎么注册

用钉钉可以玩哪些内容软件

钉钉小窗口模式在哪里设置

怎么激活钉钉?