- iOS/Objective-C 元类和类别
- objective-c - -1001 错误,当 NSURLSession 通过 httpproxy 和/etc/hosts
- java - 使用网络类获取 url 地址
- ios - 推送通知中不播放声音
下面的 java 代码示例使用 java DelayQueue 来处理任务。然而,从另一个线程插入任务似乎会破坏(我的)预期行为。
很抱歉代码示例太长,但总而言之:
我从代码示例中得到的输出是:
------initial tasks ---------------
task A due in 0ms
task B due in 9ms
task C due in 99ms
task D due in 999ms
task E due in 9999ms
task F due in 99999ms
------processing--------------------
time = 5 task A due in -1ms
time = 14 task B due in 0ms
time = 104 task C due in 0ms
time = 1004 task D due in 0ms
time = 3003 added task Z due in 0ms
------remaining after 15007ms -----------
task F due in 84996ms
task E due in -5003ms
task Z due in -12004ms
我的问题是:为什么在 15000 毫秒后 DelayQueue 中仍然有过期的任务(即 GetDelay() 返回 -ve 值的地方)?
我检查过的一些东西:
我最感兴趣的是了解如何解决这个问题。预先感谢您的协助。 (以及所有那些帮助我约会的 Stack Overflow 答案 :)
package test;
import java.util.concurrent.DelayQueue;
import java.util.concurrent.Delayed;
import java.util.concurrent.TimeUnit;
public class Test10_DelayQueue {
private static final TimeUnit delayUnit = TimeUnit.MILLISECONDS;
private static final TimeUnit ripeUnit = TimeUnit.NANOSECONDS;
static long startTime;
static class Task implements Delayed {
public long ripe;
public String name;
public Task(String name, int delay) {
this.name = name;
ripe = System.nanoTime() + ripeUnit.convert(delay, delayUnit);
}
@Override
public boolean equals(Object obj) {
if (obj instanceof Task) {
return compareTo((Task) obj) == 0;
}
return false;
}
@Override
public int hashCode() {
int hash = 7;
hash = 67 * hash + (int) (this.ripe ^ (this.ripe >>> 32));
hash = 67 * hash + (this.name != null ? this.name.hashCode() : 0);
return hash;
}
@Override
public int compareTo(Delayed delayed) {
if (delayed instanceof Task) {
Task that = (Task) delayed;
return (int) (this.ripe - that.ripe);
}
throw new UnsupportedOperationException();
}
@Override
public long getDelay(TimeUnit unit) {
return unit.convert(ripe - System.nanoTime(), ripeUnit);
}
@Override
public String toString() {
return "task " + name + " due in " + String.valueOf(getDelay(delayUnit) + "ms");
}
}
static class TaskAdder implements Runnable {
DelayQueue dq;
int delay;
public TaskAdder(DelayQueue dq, int delay) {
this.dq = dq;
this.delay = delay;
}
@Override
public void run() {
try {
Thread.sleep(delay);
Task z = new Task("Z", 0);
dq.add(z);
Long elapsed = System.currentTimeMillis() - startTime;
System.out.println("time = " + elapsed + "\tadded " + z);
} catch (InterruptedException e) {
}
}
}
public static void main(String[] args) {
startTime = System.currentTimeMillis();
DelayQueue<Task> taskQ = new DelayQueue<Task>();
Thread thread = new Thread(new TaskAdder(taskQ, 3000));
thread.start();
taskQ.add(new Task("A", 0));
taskQ.add(new Task("B", 10));
taskQ.add(new Task("C", 100));
taskQ.add(new Task("D", 1000));
taskQ.add(new Task("E", 10000));
taskQ.add(new Task("F", 100000));
System.out.println("------initial tasks ---------------");
Task[] tasks = taskQ.toArray(new Task[0]);
for (int i = 0; i < tasks.length; i++) {
System.out.println(tasks[i]);
}
System.out.println("------processing--------------------");
try {
Long elapsed = System.currentTimeMillis() - startTime;
while (elapsed < 15000) {
Task task = taskQ.poll(1, TimeUnit.SECONDS);
elapsed = System.currentTimeMillis() - startTime;
if (task != null) {
System.out.println("time = " + elapsed + "\t" + task);
}
}
System.out.println("------remaining after " + elapsed + "ms -----------");
tasks = taskQ.toArray(new Task[0]);
for (int i = 0; i < tasks.length; i++) {
System.out.println(tasks[i]);
}
} catch (InterruptedException e) {
}
}
}
最佳答案
因为您的comapareTo
方法充满缺陷。正确的实现如下。一旦你像下面这样改变,你所有的问题都会得到解决。如果或遵守 compareTo
Contract
compareTo
方法
return Long.valueOf(this.ripe).compareTo(that.ripe);
关于java.util.concurrent.DelayQueue 忽略过期元素,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/12142025/
当您在 memcached 中设置 key 过期时,它实际上是在过期时被删除,还是在请求 key 时被删除(get)并且有效期已过。换句话说,过期会自动从 memcached 中删除值,还是简单地将其
Microsoft 是否已将客户端 secret 的有效期更改为最长 2 年?不能再选择“从不”了吗? 最佳答案 我自己也遇到了这个问题。您可以使用Powershell设置添加2年以上的凭据。所以我猜
我正在尝试对我网站上的 csv 文件强制禁止缓存。 我根据 apache 的文档将这些行添加到 httpd.conf: ExpiresActive On ExpiresDefault A0 Expi
我对 Cookie 不熟悉,希望让此 Cookie 在我的注销页面上过期 这是我设置 cookie 的位置: setcookie("loggood", "YES", $expire, "/",
MySQL 是否有某种功能可以在 x 秒后使特定行过期? 例如,我必须以下数据库: users id - integer name - string subscriptions
我的机器上安装了 Matlab Compiler Runtime。它工作正常,但现在当我运行一些需要它的代码时,我得到了这个错误: Failed to initialize MCR Instance:
当我从 PayPal 收到 IPN 时,我不想立即处理它,而是将消息排队,然后使用调度程序处理它。 因此,有一点让我担心 - 如果我将一条消息排队并只处理它(包括'_notify-validate'验
关于 PHP session 过期的问题。 如果该用户有一段时间不活动(出于测试目的,5 秒),我需要我的服务器丢弃 session 信息。 我看过this question尤其是 Gumbo(+28
我有一个 session ,在 30 分钟不活动后或 23.4 小时后被销毁。 我遇到的问题是无论事件如何, session 都会在 30 分钟后被销毁。因此,如果用户在 23.4 小时内一直处于事件
我一直在网上搜索并找到了许多奇怪的答案,而且我几乎尝试了所有这些答案。我的问题是这样的。我的登录页面包含: FormsAuthenticationTicket ticket = new FormsAu
我正在构建一个表单,我必须将数据存储在 HTML5 的 sessionStorage 中 我不知道 sessionStorage 何时过期。谁能告诉我 sessionStorage 的过期时间? 最佳
在我的应用程序中,我有一个必须始终有效的访问 token (Spotify 的)。当此访问 token 过期时,应用必须每 60 分钟刷新一次 token 端点并获取另一个访问 token 。 Aut
我们的办公室有一个简单的闭路电视系统,可以显示我们每个安全摄像头的实时图像。闭路电视系统没有 API 或任何提取实时图像的方法。但是,您可以通过创建带有图像链接的基本 HTML 页面从另一个浏览器查看
我正在基于DotNetOpenAuth实现OAuth2授权/资源服务器。我的服务器将发出生命周期很长的访问 token 。这些 token 将在iOS设备上使用。我看到的流程是这样的:1)要求用户在i
请帮助我在 Varnish 配置中添加过期 header 。 max_age 已在 vcl_fetch 中定义,需要根据 max_age 添加 expires header。 最佳答案 通常不需要设置
我正在开发一个必须使用 session 超时的应用程序。 问题是用户经常错过 session 超时并丢失数据。我已经在 javascript 中实现了一个小型 session 管理器,如果浏览器中有一
我有一个应用程序,可以从我的Instagram帐户中提取数据。 我曾经授权过此应用一次,并获得了访问 token 。但是我很担心 如果该 token 过期怎么办?我是否应该在每次 token 到期?
我在数据表中有多个复选框,它们具有一个名称和不同的值,我可以通过以下代码为所有选中的复选框存储 cookie $(document).ready(function(){ $('i
hibernate 3.3.x、ehcache 2.2.x The following error occurs, when I try to publish a lots of users in a
在 Azure 门户的通知中心的“配置”选项卡上,我能够生成主键和辅助键。我了解这些是获得对 Azure API 的编程访问权限所必需的 - 允许我的客户端应用程序创建注册并发送消息。 谁能解释一下:
我是一名优秀的程序员,十分优秀!