Ошибка синхронизации в регистраторе стиля потребителя / производителя - PullRequest
Новая
       23

Ошибка синхронизации в регистраторе стиля потребителя / производителя

0 голосов
/ 10 марта 2019

Я вижу много вопросов такого рода, но никто не помог мне, поэтому я публикую свои.

Я сделал регистратор для многопоточной регистрации. Только один поток (созданный при создании самого первого регистратора.) Обрабатывает сообщения журнала из многих потоков, и буфер синхронизируется с помощью переменных условия. Один для push() и один для pop().

Казалось, что работает нормально, но не работает, когда дело касается слишком большого количества сообщений за короткое время.

Вот сообщение об исключительной ситуации от xutility. 

Exception thrown: read access violation.
_Pnext was 0xFFFFFFFFFFFFFFFF.

А это мой код.

logger.h 

class ConsoleLogger
{
private:
    static Buffer<std::string, 1000> buffer;
    uint32_t curLine = 0;
    static bool instantiated;
    std::mutex logLock;
    std::string prefix;
    std::ostringstream logStream;

    // creates log thread one very first logger calls constructor
    void createLogThread();
    // keeps logging incoming logs
    static void logThreadFunc();

public:
    ConsoleLogger();
    void setPrefix(const std::string_view& newPrefix);

    template<typename T, typename... Types>
    void log(T log1, Types... logs) {
        {
            std::scoped_lock<std::mutex> lock(logLock);
            noLog = false;

            logStream.clear();
            logStream.str("");
            logStream << prefix << "#" << curLine << "\t" << std::this_thread::get_id() << "\t";
            ++curLine;

            logMessage(log1, logs...);
        }
    }

private:
    void logMessage() {
        logStream << "\n";

        std::string* str = new std::string{ logStream.str() };

        buffer.push(str);
    }

    template<typename T, typename... Types>
    void logMessage(T log1, Types... logs) {
        logStream << log1;
        logMessage(logs...);
    }
};

logger.cpp 

Buffer<std::string, 1000> ConsoleLogger::buffer;

void ConsoleLogger::logThreadFunc() {
    while (true) {
        std::string* log = buffer.pop();
        if (log == nullptr) {
            std::cerr << "log was nullptr" << std::endl;
            continue;
        }
        std::cout << *log;
        delete log;          <-------------throws exception

    }
}

buffer.h 

template<class T, uint64_t Qsize>
class Buffer
{
private:
    T* arrayPtr[Qsize];
    uint64_t head;
    uint64_t tail;
    static const uint64_t mask = Qsize - 1;

    std::condition_variable condEmpty;
    std::condition_variable condOverflow;
    std::mutex mtx;
public:
    Buffer();

    void push(T* x);
    T* pop();
};

template <class T, uint64_t Qsize>
Buffer<T, Qsize>::Buffer() : head(0),
                             tail(0)
{}

template <class T, uint64_t Qsize>
void Buffer<T, Qsize>::push(T* x)
{
    std::unique_lock<std::mutex> lock(mtx);

    condOverflow.wait(lock, [this]() {
        return tail + Qsize > head;
        });

    arrayPtr[head++ & mask] = x;

    lock.unlock();
    condEmpty.notify_one();
}

template <class T, uint64_t Qsize>
T* Buffer<T, Qsize>::pop()
{
    std::unique_lock<std::mutex> lock(mtx);

    condEmpty.wait(lock, [this]() {
        return tail < head;
        });

    T* x = arrayPtr[tail++ & mask];

    lock.unlock();
    condOverflow.notify_one();

    return x;
}

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

Любые предложения или помощь будут очень благодарны.

1 Ответ

0 голосов
/ 10 марта 2019

Вы должны явно обнулить элементы arrayPtr

template <class T, uint64_t Qsize>
Buffer<T, Qsize>::Buffer() : head(0),
                             tail(0)
{
    for (uint64_t i = 0; i < Qsize; i++)
        arrayPtr[i] = nullptr;
}
...