Russian Qt Forum

class SearchThread : public QThread {
	Q_OBJECT
	public:
		QRegExp regexp;
		QList<Document*> list;

	protected:
		void run() {
			while (true) {
				if (list.isEmpty()) {
					break;
				}
				Document* d = list.takeFirst();

				int pos = 0;
				while (pos != -1) {
					pos = regexp.indexIn(d->Text(), pos);
					if (pos >= 0) {
						emit Result(SearchResult(d, pos));
					}
				}
			}
		}

	public:
		SearchThread(QObject* parent) {};
		
	signals:
		void Result(SearchResult);
};

class SearchResult {
	public:
		SearchResult(Document*, int) {...}
		Document* d;
		int pos p;
};

class Mediator : public QObject {
Q_OBJECT
	private:
		SearchThread thread;
		
	public:
		Mediator() {
			connect(&thread, SIGNAL(Result(SearchResult)), this, SIGNAL(Result(SearchResult)), Qt::DirectConnection);
		}
			
		void StartSearch() {thread.start();}
	
	signals:
		void Result(SearchResult);
};

class SearchThread : public QThread {
	Q_OBJECT
	public:
		QRegExp regexp;
		QList<Document*> list;
		QMutex m;

	protected:
		void run() {
			while (true) {
				m.lock();
				if (list.isEmpty()) {
					m.unlock();
					break;
				}
				Document* d = list.takeFirst();

				int pos = 0;
				while (pos != -1) {
					pos = regexp.indexIn(d->Text(), pos);
					if (pos >= 0) {
						emit Result(SearchResult(d, pos));
					}
				}
				m.unlock();
			}
		}

	public:
		SearchThread(QObject* parent) {};
		
	signals:
		void Result(SearchResult);
	public slots:
		void DeletingDocument(Document* d) {
			m.lock();
			if (list.contains(d)) {list.removeAll(d);}
			m.unlock();
		}
};

Mediator::Mediator() {
	QObject::connect(thread, SIGNAL(finished()), this, SLOT(processSearchQueue()));
}

void Mediator::StartSearch() {
	searchQueue = docs; // Копируем список всех документов в свою очередь
	processSearchQueue();
}

void Mediator::processSearchQueue() {
	if (thread->isRunning()) {return;}
	if (searchQueue.isEmpty()) {
		searchDoc = 0;
		return;
	}

	Document* d = searchQueue.takeFirst();
	searchDoc = d; // запоминаем, в каком документе в данный момент производится поиск
	thread->SetDoc(d);
	thread->start();
}

void Mediator::DeletingDocument(Document* d) { // удаление документа

	while(searchDoc == d) { // если в данный момент ищем в нём, то подождем, пока не закончится поиск
		QCoreApplication::processEvents(QEventLoop::ExcludeUserInputEvents);
	}

	searchQueue.removeOne(d);
	delete d;
}