Queue.h

Go to the documentation of this file.

/*--------------------------------*- VM2D -*-----------------*---------------*\
| ##  ## ##   ##  ####  #####   |                            | Version 1.14   |
| ##  ## ### ### ##  ## ##  ##  |  VM2D: Vortex Method       | 2026/03/06     |
| ##  ## ## # ##    ##  ##  ##  |  for 2D Flow Simulation    *----------------*
|  ####  ##   ##   ##   ##  ##  |  Open Source Code                           |
|   ##   ##   ## ###### #####   |  https://www.github.com/vortexmethods/VM2D  |
|                                                                             |
| Copyright (C) 2017-2026 I. Marchevsky, K. Sokol, E. Ryatina, A. Kolganova   |
*-----------------------------------------------------------------------------*
| File name: Queue.h                                                          |
| Info: Source code of VM2D                                                   |
|                                                                             |
| This file is part of VM2D.                                                  |
| VM2D is free software: you can redistribute it and/or modify it             |
| under the terms of the GNU General Public License as published by           |
| the Free Software Foundation, either version 3 of the License, or           |
| (at your option) any later version.                                         |
|                                                                             |
| VM2D is distributed in the hope that it will be useful, but WITHOUT         |
| ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or       |
| FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License       |
| for more details.                                                           |
|                                                                             |
| You should have received a copy of the GNU General Public License           |
| along with VM2D.  If not, see <http://www.gnu.org/licenses/>.               |
\*---------------------------------------------------------------------------*/
 
 
#ifndef QUEUE_H
#define QUEUE_H
 
#include "defs.h"
#include "Parallel.h"
#include "Task.h"
 
#ifdef CODE2D
    namespace VM2D
    {
        class World2D;
    }//namespace VM2D
#endif
 
#ifdef CODE3D
    namespace VM3D
    {
        class World3D;
    }//namespace VM3D
#endif
 
namespace VMlib
{
    
    class WorldGen;
 
    class Queue
    {
    private:
 
        struct
        {
            int prepared;
 
            int solving;
 
            int finished;
        } numberOfTask;
 
        std::vector<int> procState;
 
        std::vector<int> procStateVar;
 
        std::vector<int> flagFinish;
 
        int myidAll;
 
        int nProcAll;
 
#ifdef USE_MPI
        MPI_Group groupAll;
 
        MPI_Group groupStarting;
 
        MPI_Comm commStarting;
 
        MPI_Group groupSolving;
 
        MPI_Comm commSolving;
#else
        int groupAll;
        int groupStarting;
        int commStarting;
        int groupSolving;
        int commSolving;
#endif
 
        int sizeCommSolving;
 
        void ConstructProcStateVar();
 
        void AddTask(int _nProc, std::unique_ptr<PassportGen> _passport);
 
        LogStream info;
 
    public:
        std::vector<Task> task;
 
        std::unique_ptr<WorldGen> world;
 
        int myProcState;
 
        int myProcStateVar;
 
        const double kvantTime = 1.0;
 
        int currentKvant;
 
        int nextKvant;
 
        Parallel parallel;
 
        Queue(int& argc, char**& argv);
 
        ~Queue();
 
        void TaskSplit();
 
        void TaskUpdate();
 
        void RunConveyer();
 
        void LoadTasksList(const std::string& _tasksFile, const std::string& _mechanicsFile, const std::string& _defaultsFile, const std::string& _switchersFile);
    };
 
}//namespace VMlib
 
#endif