ACKJOB

  1. ACKJOB jobid1 jobid2 ... jobidN

通过给定任务 ID ，向节点告知任务已经被执行。

接收到 ACK 消息的节点会将该消息复制至多个节点，并尝试对任务和来自集群的 ACK 消息进行垃圾回收操作，从而释放被占用的内存。

  1. disque> GETJOB FROM greeting                    -- 取出三个任务，然后确认其中两个已被执行
  2. 1) 1) "greeting"
  3. 2) "DI216f7fa17693623ffb3bd8b0902e134f4ab6a5d305a0SQ"
  4. 3) "hello world!"
  5.  
  6. disque> GETJOB FROM greeting
  7. 1) 1) "greeting"
  8. 2) "DI216f7fa16a8e4a7428b18c2b0ec180963795b0b705a0SQ"
  9. 3) "good morning!"
  10.  
  11. disque> GETJOB FROM greeting
  12. 1) 1) "greeting"
  13. 2) "DI216f7fa11413878f376588c85aca7c7fa22232f905a0SQ"
  14. 3) "bye bye~"
  15.  
  16. disque> ACKJOB DI216f7fa17693623ffb3bd8b0902e134f4ab6a5d305a0SQ
  17. (integer) 1
  18.  
  19. disque> ACKJOB DI216f7fa11413878f376588c85aca7c7fa22232f905a0SQ
  20. (integer) 1