Ruby, MongoDB: Как поделиться курсором между потоками?

Question

Следующие не работают. Вызов resource.next_document внутри потока возвращает nil. Тот же вызов без потоковой обработки работает, как ожидалось.

Есть ли у специалистов MongoDB? : P

resources = db[Resource::COLLECTION].find 

    number_of_threads.times do 
    threads << Thread.new do 
     while resource = resources.next_document 
     puts 'one more doc' 
     end 
    end 
    end 

Answer 1

Хотя сам водитель поточно, люди курсора нет, поэтому вы не можете надежно обрабатывать данные в пути вы описываете.

Одна из возможностей состоит в том, чтобы иметь один поток, который выполняет итерацию по документам, передавая их любому количеству рабочих потоков для фактической обработки.

Answer 2

Это решение, которое я закончил с использованием:

Обратная связь Добро пожаловать

pool = DocumentPool.new(db) 
5.times do 
    Thread.new do 
    while doc = pool.next_document 
     #something cool 
    end 
    end 
end 


class DocumentPool 
    COLLECTION = 'some_collection' 

    def initialize(db) 
    @db = db     
    @first_doc = cursor.next_document  
    end 

    def collection 
    @db[COLLECTION] 
    end 

    def cursor 
    @cursor ||= collection.find 
    end 

    def shift 
    doc = nil 
    if @first_doc 
     doc = @first_doc 
     @first_doc = nil 
    else 
     doc = cursor.next_document  
    end 
    doc 
    end        

    def count 
    collection.count 
    end 
end