Jak przetasować zadania w kolejce Resque?

Question

Mam kolejkę o nazwie check_integrity i wiele zadań w nim. Kiedy uruchamiam dla niego pracownika, zajmuje pierwsze miejsce w pierwszej kolejności. Czy można przetasować zadania w tej konkretnej kolejce? Potrzebuję pracownika do losowego podjęcia pracy. Proszę pomóż.

Dzięki.

Answer 1

Spójrz na to plugin dla Resque. Sądzę, że to jest dokładnie to, czego potrzebujesz.

Answer 2

można użyć Delayed_job

Answer 3

Jeśli nie przeszkadza małpa łatanie Resque następnie można użyć tego rozwiązania:

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 

Jeśli używasz szyn utworzyć plik wewnątrz inicjalizatorów z tym kodem i zostaniesz ustawiony.

Answer 4

Jednym ze sposobów, aby go o to, by pojawiały wpisy z kolejki, Składowanie je, tasowanie partię, a następnie włóż je ponownie:

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 

Jest to bardzo przydatne, gdy błędnie enqueue kilka miejsc pracy w efekcie wyścigi na wspólne zasoby, blokady i tak dalej.