当前位置：首页 > 软件库 > 程序开发 > 作业/任务调度 >

jesque

Java 版的 Resque

授权协议 Apache

开发语言 Java

所属分类程序开发、作业/任务调度

软件类型开源软件

地区不详

投递者翁阳曜

操作系统跨平台

开源组织无

适用人群未知

软件官网

软件文档

官方下载

软件概览

jesque 是 Resque 的Java语言实现版。

使用示例：

// Configuration
final Config config = new ConfigBuilder().build();
// Add a job to the queue
final Job job = new Job("TestAction", 
    new Object[]{ 1, 2.3, true, "test", Arrays.asList("inner", 4.5)});
final Client client = new ClientImpl(config);
client.enqueue("foo", job);
client.end();
// Add a job to the delayed queue
final Job job = new Job("TestAction", 
    new Object[]{ 1, 2.3, true, "test", Arrays.asList("inner", 4.5)});
final long delay = 10; // in seconds
final long future = System.currentTimeMillis() + (delay * 1000); // timestamp
final Client client = new ClientImpl(config);
client.delayedEnqueue("fooDelay", job, future);
client.end();
// Start a worker to run jobs from the queue
final Worker worker = new WorkerImpl(config, 
    Arrays.asList("foo"), new MapBasedJobFactory(map(entry("TestAction", TestAction.class))));
final Thread workerThread = new Thread(worker);
workerThread.start();
// Wait a few secs then shutdown
try { Thread.sleep((delay * 1000) + 5000); } catch (Exception e){} // Give ourselves time to process
worker.end(true);
try { workerThread.join(); } catch (Exception e){ e.printStackTrace(); }

使用案例

聊聊jesque的几个dao

序本文主要聊一下jesque的几个dao dao列表 FailureDAO KeysDAO QueueInfoDAO WorkerInfoDAO FailureDAO jesque-2.1.0-sources.jar!/net/greghaines/jesque/meta/dao/FailureDAO.java /** * FailureDAO provides access to job f
Jesque 基础入门

Jesque是Resque的java实现，它是一个maven项目，依赖Jedis连接到Redis，使用Jackson序列化Job信息，存储在Redis数据库中。主要用于做定时任务。添加依赖你可以去官网下载jar包，当然如果你是一个maven项目，像下面这样直接添加依赖即可： <dependency> <groupId>net.greghaines</groupId> <artifact
聊聊jesque的event机制

序本文主要介绍一下jesque的event机制 WorkerEvent jesque-2.1.2-sources.jar!/net/greghaines/jesque/worker/WorkerEvent.java /** * The possible WorkerEvents that a WorkerListener may register for. */ public enum Wo
聊聊jesque的WorkerImpl与WorkerPool

序本文主要讲一下jesque的WorkerImpl与WorkerPool。 resque Resque是一个使用redis来创建后台任务的ruby组件。而jesque是其java版本。通常用来做延时队列。 WorkerImpl List queues = Arrays.asList(delayedQueue); final Worker worker = new WorkerImpl(jesqu
jesque

软件简介 jesque 是 Resque 的Java语言实现版。使用示例： // Configuration final Config config = new ConfigBuilder().build(); // Add a job to the queue final Job job = new Job("TestAction", new Object[]{ 1, 2.3, true, "
聊聊jesque在redis中的数据结构

序本文主要介绍一下jesque在redis的存储结构示例配置 namespace=demo listen-queue=demoqueue 启动时的reids对象 127.0.0.1:6379> keys * 1) "demo:worker:Mars.local:3820-3:JAVA_DYNAMIC_QUEUES,demoqueue:started" 2) "demo:worker:Mars.
Java 版的 Resque jesque

软件介绍 jesque 是 Resque 的Java语言实现版。使用示例：// Configuration final Config config = new ConfigBuilder().build(); // Add a job to the queue final Job job = new Job("TestAction", new Object[]{ 1, 2.3, true, "t

jesque

同类工具

相关阅读

相关文章

相关问答

相关文档