Làm thế nào để xáo trộn công việc trong hàng đợi Resque?

Question

Tôi có một hàng đợi có tên là check_integrity và rất nhiều công việc trong đó. Khi tôi chạy một công nhân cho nó nó có công việc đầu tiên trong lần đầu tiên ra lệnh. Có thể trộn các công việc trong hàng đợi cụ thể đó không? Tôi cần công nhân làm việc ngẫu nhiên. Hãy giúp tôi.

Cảm ơn.

Answer 1

Hãy xem điều này plugin cho Resque. Tôi đoán đây là chính xác những gì bạn cần.

Answer 2

bạn có thể sử dụng Delayed_job

Answer 3

Nếu bạn không nhớ khỉ vá resque sau đó bạn có thể sử dụng giải pháp này:

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 

Nếu đang sử dụng đường ray tạo ra một tập tin bên trong initializers với mã đó và bạn sẽ được thiết lập.

Answer 4

Một cách để đi về việc này là bởi popping mục ra khỏi hàng đợi, Trạm trộn chúng lên, xáo trộn hàng loạt và sau đó tái chèn chúng:

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 

Điều này thực sự hữu ích khi bạn nhầm lẫn enqueue một số công việc mà kết thúc cuộc đua cho các tài nguyên được chia sẻ, ổ khóa và như vậy.