Russian Qt Forum

C++ (Qt)
void ThreadClass::run( void )
{
  while (true) {
   theSemaphore.acquire(); // ждем заданий от главной нитки
   theMutex.lock();            // извлекаем задание
   CTask task = theTaskList.takeAt(0); 
   theMutex.unlock();
 
   if (task.imagePath == NULL)  break;  // пустое имя значит завершить нитку
   task.OpenImage();  // занимаемся имеджем
   emit signalLoad(task.imagePath); // сообщаем что загрузили
   task.ScaleImage();  // масштабим
   emit signalScaled(task.imImage); // сообщаем что готово
  }  
}
 

C++ (Qt)
void AddImage2Process( const CTask & task )
{
  QMutexLocker locker(&theMutex);
  theTaskList.push_back(task);
  theSemaphore.release();   // есть работа для ниток-загрузчиков
}
 

C++ (Qt)
void ThreadClass::run()
{
	while (true) 
	{
		MegaTransformer::semaphore.acquire(); // ждем заданий от главной нитки
		MegaTransformer::mutex.lock();            // извлекаем задание
 
		TaskClass task = MegaTransformer::taskList.takeAt(0);
		MegaTransformer::mutex.unlock();
 
		if (task.imagePath == NULL)  break;  // пустое имя значит завершить нитку
 
		task.OpenImage(); // загрузка изображения
		emit signalLoad(task.numberOfImage, task.imagePath); // сообщаем что загрузили
 
// ==========================================================================================
// ВИДИМО ВОТ ЭТУ ЧАСТЬ ЛУЧШЕ ВСЕГО ВЫДЕЛИТЬ В ОТДЕЛЬНЫЙ ПОТОК ? ТОЧНЕЕ ПО ПОТОКУ НА ОПЕРАЦИИ А, В
		task.OperationA();  // Операция А
		task.OperationВ();  // Операция В
// ==========================================================================================
 
                  emit AllOperationsFinished(...); // ждем выполнения операций А, В
 
		... выполнение операции 4 + ожидание выполнения
 
		... выполнение операции 5 + ожидание выполнения
	}
}

C++ (Qt)
bool TaskClass::Process( void ) 
{
  switch (mCommand) {
   case cmd_OpenImage:
     OpenImage():    // выполняем команду
     ...
     AddImage2Process(CTask(cmd_ScaleImage, ...);  // помещаем новую команду в очередь
     break;
 
   case cmd_ScaleImage:
    ...
    break;
 
   case cmd_EndOfJob:   // специальная команда - выйти 
     return false;
  }
  return true;
}
 

case cmd_OpenImage:
     OpenImage():    // выполняем команду
     ...
     AddImage2Process(CTask(cmd_ScaleImage, ...);  // помещаем новую команду в очередь
     break;

C++ (Qt)
QList<TaskClass> MegaTransformer::taskList;
 
void MegaTransformer::loadImages()
{
	QStringList imagesPath = QFileDialog::getOpenFileNames(...)
 
	for(int i=0; i<imagesPath.length();i++)
	{
		AddImageToProcess(imagesPath[i]);
	}
 
	threads->start();
}
 
void MegaTransformer::AddImageToProcess(QString imagePath)
{
	QMutexLocker locker(&mutex);
 
	TaskClass task; // создание объекта TaskClass 
           // ... и последующее заполнение ...
 
	taskList.push_back(task); // добавление задачи в очередь
	semaphore.release();   // есть работа для ниток-загрузчиков
}
 
void ThreadClass::run()
{
	while (true) 
	{
		MegaTransformer::semaphore.acquire(); // ждем заданий от главной нитки
		MegaTransformer::mutex.lock();        // извлекаем задание
 
		TaskClass task = MegaTransformer::taskList.takeAt(0);
		MegaTransformer::mutex.unlock();
 
		task.OpenImage(); // загрузка изображения
		emit signalLoad(task.numberOfImage, task.imagePath); // сообщаем что загрузили
		// .....
	}
}

C++ (Qt)
class ThreadClass : public QThread
{ 
   ...
   signals:
     void signalHomo(std::list<double>);
}
 
ThreadClass::run()
{
  ....
  std::list<double> matrix;
  ...
  emit signalHomo(matrix);
}
 
class MegaTransformer : public QMainWindow
{
    ...
    private slots:
      void homoDone(std::list<double>);
}
 
connect(threads, SIGNAL(signalHomo(std::list<double>)), this, SLOT(homoDone(std::list<double>)), Qt::QueuedConnection);
 
void MegaTransformer::homoDone(std::list<double> matrix)
{
   // сигнал не поступает :(
}

C++ (Qt)
qRegisterMetaType< QList<double> >( "QList<double>" );