Потоки и философы

Question

mihenze19 ноября 2017 г. 5:20

Потоки и философы

Здравствуйте, реализовал обедающих философов с помощью семафоров. Но возник вопрос, как это сделать использую QMutex или QSemaphore, а не как я с помощью условий. Очень буду благодарен за помощь.

Ps. И еще такой вопрос, как в моем коде остановить потоки по кнопке стоп, а затем, если нажать старт, симуляция обеда начиналась заново? (Я так понимаю, нужно выставлять флаг цикла while в слоте life() в false, а затем вызывать для потока terminate()? )

mainwindow.h

#ifndef MAINWINDOW_H
#define MAINWINDOW_H

#include <QMainWindow>
#include <QThread>
#include <QStringList>
#include <QTableView>
#include <QStandardItemModel>
#include <QVector>

#include "philosopher.h"
#include "fork.h"

namespace Ui {
class MainWindow;
}

class MainWindow : public QMainWindow
{
    Q_OBJECT

public:
    explicit MainWindow(QWidget *parent = 0);
    ~MainWindow();

public slots:
    void slotStart(); //начало эмуляции
    void slotStop(); //завершение эмуляции
    void slotTextOutput(QString sOut); //вывод текста в textedit

private:
    Ui::MainWindow *ui;

    QThread thread1;
    QThread thread2;
    QThread thread3;
    QThread thread4;
    QThread thread5;
    QVector <Fork> list_fork;
    int listing = 1;
};

#endif // MAINWINDOW_H

mainwindow.cpp

#include "mainwindow.h"
#include "ui_mainwindow.h"

MainWindow::MainWindow(QWidget *parent) :
    QMainWindow(parent),
    ui(new Ui::MainWindow)
{
    ui->setupUi(this);

    connect(ui->action, SIGNAL(triggered(bool)), this, SLOT(slotStart()));
    connect(ui->action_2, SIGNAL(triggered(bool)), this, SLOT(slotStop()));

}

MainWindow::~MainWindow()
{
    delete ui;
}
void MainWindow::slotStart()
{
    for (int i = 0; i < 5; i++)
    {
        Fork fork;
        list_fork.push_back(fork);
    }

    Philosopher *phil1 = new Philosopher("Socrat", &list_fork, 0);
    Philosopher *phil2 = new Philosopher("Arestotel", &list_fork, 1);
    Philosopher *phil3 = new Philosopher("Platon", &list_fork, 2);
    Philosopher *phil4 = new Philosopher("Evklid", &list_fork, 3);
    Philosopher *phil5 = new Philosopher("Diogen", &list_fork, 4);


    connect(phil1, SIGNAL(signalAddText(QString)), this, SLOT(slotTextOutput(QString)));
    connect(phil2, SIGNAL(signalAddText(QString)), this, SLOT(slotTextOutput(QString)));
    connect(phil3, SIGNAL(signalAddText(QString)), this, SLOT(slotTextOutput(QString)));
    connect(phil4, SIGNAL(signalAddText(QString)), this, SLOT(slotTextOutput(QString)));
    connect(phil5, SIGNAL(signalAddText(QString)), this, SLOT(slotTextOutput(QString)));


    connect(&thread1, SIGNAL(started()), phil1, SLOT(life()));
    connect(&thread2, SIGNAL(started()), phil2, SLOT(life()));
    connect(&thread3, SIGNAL(started()), phil3, SLOT(life()));
    connect(&thread4, SIGNAL(started()), phil4, SLOT(life()));
    connect(&thread5, SIGNAL(started()), phil5, SLOT(life()));


    phil1->moveToThread(&thread1);
    phil2->moveToThread(&thread2);
    phil3->moveToThread(&thread3);
    phil4->moveToThread(&thread4);
    phil5->moveToThread(&thread5);


    thread1.start(QThread::NormalPriority);
    thread2.start(QThread::NormalPriority);
    thread3.start(QThread::NormalPriority);
    thread4.start(QThread::NormalPriority);
    thread5.start(QThread::NormalPriority);
}

void MainWindow::slotStop()
{


}

void MainWindow::slotTextOutput(QString sOut)
{
    QString sss = QString::number(listing);
    sss+= ": " + sOut;

    ui->plainTextEdit->appendPlainText(sss);
    listing++;
}

fork.h

#ifndef FORK_H
#define FORK_H


class Fork
{
public:
    Fork();

    bool getIsUsing() const;
    void take();
    void put();

private:
    bool isUsing;
};

#endif // FORK_H

fork.cpp

#include "fork.h"

Fork::Fork()
{
    isUsing = false;
}

bool Fork::getIsUsing() const
{
    return isUsing;
}

void Fork::take()
{

    isUsing = true;
}

void Fork::put()
{

    isUsing = false;
}

philosopher.h

#ifndef PHILOSOPHER_H
#define PHILOSOPHER_H

#include <QObject>
#include <windows.h>
#include <QVector>

#include "fork.h"

class Philosopher : public QObject
{
    Q_OBJECT
public:
    Philosopher(QString s, QVector<Fork> *fork, int id);

    void eat();
    void think();
    void takeForks();
    void putForks();
signals:
    void signalAddText(QString);

public slots:
    void life();

private:
    QString name;
    bool left_fork;
    bool right_fork;
    QVector <Fork> *forkNumber;
    int idPhil;
};

#endif // PHILOSOPHER_H

philosopher.cpp

#include "philosopher.h"

Philosopher::Philosopher(QString s, QVector<Fork> *fork, int id) : name(s)
{
    left_fork = false;
    right_fork = false;
    forkNumber = fork;
    idPhil = id;
}

void Philosopher::eat()
{
    QString temp = name + " кушает.";
    Sleep(1000);
    emit(signalAddText(temp));
}

void Philosopher::think()
{
    QString temp = name + " думает.";
    Sleep(1000);
    emit(signalAddText(temp));
}

void Philosopher::takeForks()
{
    if((!(*forkNumber)[idPhil].getIsUsing())&&(!(*forkNumber)[(idPhil+4)%5].getIsUsing()))
    {
        (*forkNumber)[idPhil].take();
        left_fork = true;
        (*forkNumber)[(idPhil+4)%5].take();
        right_fork = true;
        QString temp = name + " взял вилки.";

        emit(signalAddText(temp));
        Sleep(1000);

    }
}

void Philosopher::putForks()
{
    QString temp = name + " положил вилки.";

    emit(signalAddText(temp));

    (*forkNumber)[idPhil].put();
    left_fork = false;

    (*forkNumber)[(idPhil+4)%5].put();
    right_fork = false;

    Sleep(1000);
}

void Philosopher::life()
{
    while(true)
    {
        think();
        takeForks();
        if (left_fork && right_fork)
        {
            eat();
            putForks();

        }
    }
}

PhilosopherSimulator.rar

Потоки и философы

Рекомендуем хостинг TIMEWEB

Комментарии