def METHOD_NAME():
    """queue_reader"""
    queue = multiprocessing.Queue(queue_size)
    for reader in readers:
        p = multiprocessing.Process(
            target=_read_into_queue, args=(reader, queue))
        p.start()
    reader_num = len(readers)
    finish_num = 0
    while finish_num < reader_num:
        sample = deserialize_data(queue.get())
        if sample is None:
            finish_num += 1
        else:
            yield sample