Поиск слов в файле в Qt

[stasJun]

Я переделал через Мютекс, думал может так будет быстрее работать и правильно нифига(wait и т.д)(

#include "FindWordInFileThread.h"

#include <QFile>
#include <QTextStream>
#include <QFileInfo>

FindWordInFileThread::FindWordInFileThread(const std::vector<QString>& filePath, const QString& word, size_t startIndex, size_t numElements, std::vector<QString>& foundFiles, QMutex* mutex)
    : mFilePath(filePath)
    , mWord(word)
    , mStartIndex(startIndex)
    , mNumElements(numElements)
    , mFoundFiles(foundFiles)
    , mMutex(mutex)
    , mIsCancelled(false)
{}

void FindWordInFileThread::run()
{
    mCachedFiles.clear();
    for (size_t index = mStartIndex; index < mStartIndex + mNumElements; ++index)
    {
        QFile file(mFilePath[index]);
        if (!file.open(QIODevice::ReadOnly | QIODevice::Text))
            return;

        QTextStream textStream(&file);
        while (!textStream.atEnd())
        {
            QString line = textStream.readLine();
            if (line.contains(mWord, Qt::CaseInsensitive))
            {
                mCachedFiles.push_back(QFileInfo(mFilePath[index]).fileName());
                break;
            }
            if (mIsCancelled)
                return;
        }
        emit completed(QFileInfo(mFilePath[index]).size());
        file.close();
    }
    if (!mCachedFiles.empty())
    {
        QMutexLocker locker(mMutex);
        mFoundFiles.insert(mFoundFiles.end(), mCachedFiles.begin(), mCachedFiles.end());
    }
}
void FindWordInFileThread::cancelClicked()
{
    mIsCancelled = true;
}

[stasJun]

Сообщение от Alex11223

а, насчет отмены и завершения, я не заметил, что там есть wait после запуска потоков.

Тогда отмена вообще не может работать, у вас же UI поток занят ожиданием завершения потоков.

И прогресс по идее тоже не обновляется во время работы, только после завершения все сразу.

да, все сразу показывает. в конце. И как с этим бороться?

[Alex11223]

Причем тут мьютекс? я ж написал в чем проблема.

[stasJun]

Сообщение от Alex11223

Причем тут мьютекс? я ж написал в чем проблема.

я не увидел ваш пост про wait сначала)
а как можно реализовать чтобы обойти wait? чтобы нормально прогрес бар работал и кансел

[Alex11223]

Не делать ничего после запуска потоков, всю обработку результата и т.п. делать только по сигналу (completed, ...)

Я бы сделал у потока 2 сигнала: completed и progressChanged.

Во втором просто передавать количество обработанных байтов: в цикле чтения если надо (только наверно лучше не каждую итерацию а как-то более редко) и в конце размер файла как сейчас.

А в completed наверно надо передавать имя файла и результат (в данном случае bool найдено/не найдено).
При его получении выводить результат и считать количество завершенных потоков для определения завершения всего поиска.

[stasJun]

Сообщение от Alex11223

Не делать ничего после запуска потоков, всю обработку результата и т.п. делать только по сигналу (completed, ...)

Я бы сделал у потока 2 сигнала: completed и progressChanged.

Во втором просто передавать количество обработанных байтов: в цикле чтения если надо (только наверно лучше не каждую итерацию а как-то более редко) и в конце размер файла как сейчас.

А в completed наверно надо передавать имя файла и результат (в данном случае bool найдено/не найдено).
При его получении выводить результат и считать количество завершенных потоков для определения завершения всего поиска.

спасибо
я все прочитал что ві написали, и не совсем понял.
void completed(bool mIsCancelled);
а от как с progressChanged сделать я не понял(

[Alex11223]

Причем тут mIsCancelled?
Ну mIsCancelled конечно тоже можно сообщать в completed и часто это бывает удобно, но не обязательно и к основной задаче не относится.

run()
{
    bool found = false;

    while (чтение файла)
    {
          emit progressChanged(текущая_позиция_в_файле); // не обязательно

          if (нашли то что искали)
          {
               found = true;
               break;
          }
    }

    emit progressChanged(размер файла);
    emit completed(имя файла, found);
}

[stasJun]

Сообщение от Alex11223

Причем тут mIsCancelled?
Ну mIsCancelled конечно тоже можно сообщать в completed и часто это бывает удобно, но не обязательно и к основной задаче не относится.

run()
{
    bool found = false;

    while (чтение файла)
    {
          emit progressChanged(текущая_позиция_в_файле); // не обязательно

          if (нашли то что искали)
          {
               found = true;
               break;
          }
    }

    emit progressChanged(размер файла);
    emit completed(имя файла, found);
}

переделал:
[CODE]signals:
void completed(QString, bool);

void FindWordInFileThread::run()
{
    bool found = false;
    mCachedFiles.clear();
    for (size_t index = mStartIndex; index < mStartIndex + mNumElements; ++index)
    {
        QFile file(mFilePath[index]);
        if (!file.open(QIODevice::ReadOnly | QIODevice::Text))
            return;

        QTextStream textStream(&file);
        while (!textStream.atEnd())
        {
            QString line = textStream.readLine();
            if (line.contains(mWord, Qt::CaseInsensitive))
            {
                found = true;
                mCachedFiles.push_back(QFileInfo(mFilePath[index]).fileName());
                break;
            }
            if (mIsCancelled)
                return;
        }
        emit progressChanged(QFileInfo(mFilePath[index]).size());
        emit completed(QFileInfo(mFilePath[index]).fileName(), found);
        file.close();
    }
    if (!mCachedFiles.empty())
    {
        QMutexLocker locker(mMutex);
        mFoundFiles.insert(mFoundFiles.end(), mCachedFiles.begin(), mCachedFiles.end());
    }
}

но выдает ошибку так как void progressChanged(qint64);
у меня в виджете а не в класе поток.

и оно не знает такую функцию :
D:\Development\Pavlik\Qt\FindFilesW idget\FindWordInFileThread.cpp:40: error: C3861: 'progressChanged': identifier not found
и у меня функцияпринимает аргумент number

void FindFilesWidget::progressChanged(qint64  number)
{
    mBytesProcessed += number;
    mProgressBar->setValue(mBytesProcessed / (double) mFileSize * 100);
}

[Alex11223]

Ну видимо у вас нет сигнала с именем progressChanged в классе потока.

и пример выше был про случай когда один поток ищет только в одном файле, для переделывания под несколько файлов как тут надо не просто скопипастить

[stasJun]

Сообщение от Alex11223

Ну видимо у вас нет сигнала с именем progressChanged в классе потока.

и пример выше был про случай когда один поток ищет только в одном файле, для переделывания под несколько файлов как тут надо не просто скопипастить

нету, он у меня этот поток в класе FindFilesWidget