- iOS/Objective-C 元类和类别
- objective-c - -1001 错误,当 NSURLSession 通过 httpproxy 和/etc/hosts
- java - 使用网络类获取 url 地址
- ios - 推送通知中不播放声音
我想遍历我的 DelayQueue 中未过期的元素。类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);
}
}
下面的 TransactionManager 类将传入的事务添加到队列中,如果新的传入事务小于 1 分钟。在 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();
}
}
在此测试中,我创建了 40 秒之前的 5 个事务和 10 秒之前的 3 个事务。所以在等待 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 个,但无法捕捉到哪里......
最佳答案
if (delayed instanceof Transaction) { return 0; }
看起来不对 - 如果您希望 compareTo
与 getDelay()
一致,您可能应该删除该位。所以你的方法应该看起来像这样(使用静态导入):
public int compareTo(Delayed delayed) {
return delayed == this
? 0
: Long.compare(getDelay(MILLISECONDS), delayed.getDelay(MILLISECONDS));
}
关于java - DelayQueue 意外行为。 DrainTo 仅从队列中删除 1 个过期项,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/45032330/
我仅在 WIN7 PC 上收到此通知,仅使用 IE。 Firefox 总是很好,旧版 Windows 上的 IE 似乎也不错。这让我大吃一惊,我不知道为什么 IE 认为 SSL 证书有问题。有没有人以
概述 对于我产品的新版本 v1.9.0,我创建了一个新的 MSI 安装程序。该应用程序的先前版本是 v1.7.0。 卸载旧版本然后安装新版本工作正常。 但是当我尝试使用 v1.9.0 安装程序更新旧版
该网站有一个全高图像启动。更多内容位于首屏下方,图像底部有一个“滚动”元素,以提示用户发现其余内容。单击后,我成功地使网站向下滚动 300 像素。然而,我想顺利地做到这一点。这是我当前的代码: w
var i = 0; function Myfunc() { var newdiv = document.createElement('div'); var el = document
这纯粹是为了学习目的;我知道 CSS 将是这种情况下的首选方法。 我知道在 JavaScript 中,您可以使用内联事件处理将鼠标悬停在图像上,如下所示: 我知道您可以在您的站点中安装 jQuery
我只想从curl请求中获取 header curl -I www.google.com 一切都很棒。现在我想这样做,但也传递发布数据: curl -I -d'test=test' www.google
以下代码旨在更改一个字段的颜色: Untitled Document var bkColor =
我正在使用 grep 递归搜索目录,并使用以下参数希望只返回第一个匹配项。不幸的是,它返回了不止一个——事实上,我上次查看时返回了两个。似乎我有太多的争论,尤其是没有得到想要的结果。 :-/ # gr
我只想搜索当前目录中的所有文件。我试过这个 grep foo * 但我收到此错误 grep: bar: Is a directory 我也尝试过这个 grep -r foo 但这也在搜索子目录。 最佳
我正在构建一个销售点应用程序,我想打印一张收据。问题是我使用的打印机无法打印纯文本的任何图形,我在 javafx 中只能找到使用 Print API 打印节点或使用像 jasper 这样都包含图形的报
是否有任何操作系统在完全加载时仅提供用于控制台应用程序执行的 java 环境?理想情况下,它会在加载时自动启动程序 最佳答案 这是一个名称为:JavaOS 的东西 从我的角度来看,更好的方法是安装一个
在工作中,我们有一个每晚执行 mysql 数据转储的脚本。对于开发,我们通常需要使用来自最近转储的数据。一段时间以来,我们一直每天都进行数据库还原,但现在我们已经到了每天还原花费近一个小时的地步。有没
我的移动模式菜单有问题。 onClick 它淡出。我想保留此设置,但我不希望它在单击下拉部分时淡出。这是链接:http://jsfiddle.net/zLLzrs6b/3/感谢您的帮助! html:
经过大量研究和反复试验,我谦虚地向各位 CSS 专家寻求帮助。这就是我需要的: 我有两张图片:titlelogo 和 newlogo。 在全屏模式下,newlogo 需要在左边,titlelogo 在
这个问题在这里已经有了答案: Exclusive CSS selector (3 个答案) 关闭 3 年前。 我的文档结构如下: ... ... something something someth
我有一个具有以下要求的表: 所有列的宽度必须可变 所有列的宽度不得超过必要的宽度 所有单元格必须保留空白(white-space:pre/pre-wrap) 当(且仅当)超过最大定义宽度 (1000p
我正在寻找一个正则表达式来仅匹配具有特殊 字符且大小为4+ 的数字 字符串。我对此处发布的问题做了一些评论: 测试网站: http://regexlib.com/RETester.aspx 1- re
我正在为我的元素开发一个纯 CSS 灯箱解决方案。我用谷歌搜索了它,但到目前为止只找到了部分解决方案。 我正在寻找这些功能: 显示任意宽任意高的内容(无固定高/宽) 垂直居中和水平居中 如果内容宽度和
出于各种原因,我目前正在尝试使用 HTML/CSS 创建网格布局(我知道 Bootstrap 等,但在这种情况下没有选择,而且我无法添加标记元素)。 我有以下代码(容器 div,每次都有一个带有 ul
有没有办法使用String.format()格式化 double 以仅获取小数? System.out.println(String.format("%.2f", 1.23456d)); 正如预期的那
我是一名优秀的程序员,十分优秀!