Come mescolare i lavori in una coda Resque?

Question

Ho una coda di nome check_integrity e molti lavori al suo interno. Quando eseguo un worker per esso, sono necessari i primi lavori nel primo ordine. È possibile mischiare i lavori in quella particolare coda? Ho bisogno che il lavoratore prenda i lavori a caso. Per favore aiuto.

Grazie.

Answer 1

Guarda questo plugin per il Resque. Immagino che questo sia esattamente ciò di cui hai bisogno.

Answer 2

è possibile utilizzare Delayed_job

Answer 3

Se non ti dispiace scimmia patch resque quindi è possibile utilizzare questa soluzione:

module Resque 

    # Monkey patch Resque to handle queues as sets instead of lists. This allows 
    # use to get jobs randomly rather then sequentially. 
    def push(queue, item) 
    watch_queue(queue) 
    redis.sadd "queue:#{queue}", encode(item) 
    end 

    def pop(queue) 
    decode redis.spop("queue:#{queue}") 
    end 

    def size(queue) 
    redis.scard("queue:#{queue}").to_i 
    end 
end 

Se si utilizza rotaie creare un file all'interno delle inizializzatori con quel codice e sarai impostato.

Answer 4

Un modo per andare su questo è da popping voci dalla coda, li il dosaggio fino, mischiare il lotto e poi reinserirle:

key = "resque:queue:bulk" 
total = Redis.current.llen(key) 
batch_size = 5_000 # any value that is good enough for you 

batch = [] 
total.times do |i| 
    entry = Redis.current.lpop(key) 
    batch << entry 
    if batch.size == batch_size 
    puts "re-inserting batch..." 
    Redis.current.rpush key, batch.shuffle 
    batch = [] 
    end 
end 

Questo è molto utile quando si Enqueue erroneamente più lavori che finiscono per correre per risorse condivise, serrature e così via.