3

所以我有 MyJob.perform_in(60, @user)，它将在 60 秒内完成我的工作。

如果再次运行这行代码并在队列中替换它，我想取消此作业。

我没有运气研究。

4

2 回答 2

0

SuckerPunch 框架内部没有内置方法，我可以从源代码中看到，取消单个排队作业或当前正在执行的作业。似乎清除作业队列是一个全有或全无的功能。

也就是说，添加一个扩展方法来查询底层 ConcurrentTask 框架并根据 @user 参数的值将新作业与已排队的作业匹配起来应该是一件小事。

于 2016-09-30T20:41:13.727 回答
0

获取与 SuckerPunch 工作相关的统计信息

[14] pry(main)> SuckerPunch::Queue.stats
{
    "CreateVVLinkJob" => {
        "workers" => {
            "total" => 1,
             "busy" => 0,
             "idle" => 1
        },
           "jobs" => {
            "processed" => 1,
               "failed" => 0,
             "enqueued" => 0
        }
    }
}

并清除以前的工作

[24] pry(main)> SuckerPunch::Queue.clear
[
    [0] #<SuckerPunch::Queue:0x0000000b150da0 @__lock__=#<Mutex:0x0000000b150d50>, @__condition__=#<Thread::ConditionVariable:0x0000000b150d28>, @running=false, @name="CreateVVLinkJob", @pool=#<Concurrent::ThreadPoolExecutor:0x0000000b146ad0 @__lock__=#<Mutex:0x0000000b1469e0>, @__condition__=#<Thread::ConditionVariable:0x0000000b1469b8>, @min_length=2, @max_length=2, @idletime=60, @max_queue=0, @fallback_policy=:abort, @auto_terminate=false, @pool=[], @ready=[], @queue=[], @scheduled_task_count=1, @completed_task_count=1, @largest_length=1, @ruby_pid=22314, @gc_interval=30, @next_gc_time=25973.834404648, @StopEvent=#<Concurrent::Event:0x0000000b1468c8 @__lock__=#<Mutex:0x0000000b146878>, @__condition__=#<Thread::ConditionVariable:0x0000000b146850>, @set=true, @iteration=0>, @StoppedEvent=#<Concurrent::Event:0x0000000b1467d8 @__lock__=#<Mutex:0x0000000b146788>, @__condition__=#<Thread::ConditionVariable:0x0000000b146760>, @set=true, @iteration=0>>>
]

希望这是有用的！

于 2016-07-19T12:44:32.663 回答