Блог

Я создал функцию, которая сохраняет данные без знака char* в двоичный файл. Процесс реализуется в отдельном потоке и должен добавлять данные, полученные из очереди (boost::lockfree::очередь). Мой SSD-накопитель теоретически способен развивать скорость записи до ~5000 Мбит/с, однако я заметил, что она вряд ли когда-либо превышает 500 Мбит/с. Я нахожусь на платформе Windows, если это имеет значение. В чем может быть узкое место в приведенном ниже коде?

Настройка: канал камеры —> плата сбора изображений —>> запись данных в память —>>> данные очереди с помощью boost::без блокировки::очередь —>>>> всплывающие данные по требованию —>>>>> сохранить в двоичный файл

 void SaveData::saveAsBinary(std::string filePath, DataFeed *d)
{
    saveThreadADone = false;    // std::atomic<bool> flag

    std::thread storeDataThread([this, filePath, d] {

    std::ofstream file = open(filePath, std::ios::beg | std::ofstream::out | std::ofstream::ate | std::ofstream::binary);
    if(outputFile.fail()){
        throw std::runtime_error("Cannot open file for saving.");
        }
   
        while(!d->isDataEmpty()) // Assume data collection is already done
        {           
            auto bufferData = d->getData().get(); // getData returns std::unique_ptr<unsigned char[]>
            size_t bufferDataSize = sizeof (bufferData);
            file.write(reinterpret_cast<char const*>(bufferData), bufferDataSize);
            if (!file.good())
            {
                throw std::runtime_error("There was an error while saving buffer data to file.");
            }
        }
        file.close();
        this->saveThreadADone = true;
    });

    storeDataThread.join();
}

std::unique_ptr<unsigned char[]> DataFeed::getData()
{
    std::unique_ptr<unsigned char[]> output(nullptr);

    if(!dataQueue.empty()){ // boost::lockfree::queue<unsigned char*> dataQueue {100}
        dataQueue.pop(output);
    }
    return output;
}

bool DataFeed::isDataEmpty()
{
    return dataQueue.empty();
}

// Somewhere else in the code
saveData_->saveAsBinary("specifiedPath", *dataFeed);