cMainThread.h

Go to the documentation of this file.

 
#ifndef _CMAINTHREAD_H
#define _CMAINTHREAD_H
 
#include <iostream>
#include <QThread>
#include <QThreadPool>
#include <QTime>
#include <QMutex>
 
#include "core/utilities.h"
#include "core/cParameters.h"
#include "core/cDeNovoGraph.h"
#include "core/cTheoreticalSpectrum.h"
#include "core/cIsotopePatternCache.h"
 
using namespace std;
 
 
extern cIsotopePatternCache isotopepatterncache;
 
 
class cMainThread : public QThread {
    
    Q_OBJECT
 
private:
 
    bool enablelogwindow;
    bool enablestdout;
    bool terminatecomputation;
    bool graphreaderisworking;
 
    cDeNovoGraph graph;
    cTheoreticalSpectrumList* listoftheoreticalspectra;
    cParameters parameters;
 
    QMutex mutex;
 
    int paralleloutputstate;
    int paralleloutputsize;
 
    string getCurrentTime(QTime& time);
 
    void singleThreadMS1(cMainThread* os, QTime& time, cTheoreticalSpectrum* testspectrum = 0, vector< vector< vector<int> > >* testhintsindexvector = 0, cTheoreticalSpectrumList* testlistoftheoreticalspectra = 0, vector< vector<cPeaksList> >* testunmatchedpeaksvector = 0);
 
    void multiThreadMS1(cMainThread* os, QTime& time, cTheoreticalSpectrum* testspectrum = 0, vector< vector< vector<int> > >* testhintsindexvector = 0, cTheoreticalSpectrumList* testlistoftheoreticalspectra = 0, vector< vector<cPeaksList> >* testunmatchedpeaksvector = 0);
 
    void initParallelOutputState(int size);
 
    void serializeSpectrumPool(vector<cTheoreticalSpectrum*>& spectrumpool, cTheoreticalSpectrum& ts);
 
    void serializeHintsIndexPool(vector< vector< vector<int> > >& hintsindexpool, vector< vector<int> >& hintsindex);
 
    void serializeUnmatchedPeaksPool(int peaklistseriesvectorid, vector< vector<cPeaksList> >& unmatchedpeakspool, vector< vector<cPeaksList> >& unmatchedpeaks);
 
    void serializeTheoreticalSpectrumListPool(int peaklistseriesvectorid, vector<cTheoreticalSpectrumList*>& theoreticalspectrumlistpool, cTheoreticalSpectrumList& theoreticalspectrumlist);
 
    void printMatrix(cPeaksList& peaklist);
 
    void printIonEstimations(cPeaksList& peaklist);
 
 
public:
 
 
    cMainThread(cParameters& parameters, cTheoreticalSpectrumList& listoftheoreticalspectra, bool enablelogwindow = true, bool enablestdout = true);
 
 
    void setGraphReaderIsWorking(bool working);
 
 
    bool isGraphReaderWorking();
 
 
    typedef std::basic_ostream<char, std::char_traits<char> > CoutType;
 
 
    typedef CoutType& (*StandardEndLine)(CoutType&);
 
 
    template<class T> cMainThread& operator<<(const T& x) {
        if (enablelogwindow) {
            emit message(to_string(x).c_str());
        }
 
        if (enablestdout) {
            cout << x;
        }
 
        return *this;
    }
 
 
    cMainThread& operator<<(const char* x);
 
 
    cMainThread& operator<<(const string& x);
 
 
    cMainThread& operator<<(StandardEndLine manip);
 
 
    void addToParallelOutputState(int value);
 
 
protected:
 
 
    void run();
 
 
    void emitEndSignals();
 
 
signals:
 
 
    void message(QString s);
 
 
    void enableRunButtonAndSettings(bool enable);
 
 
    void enableStopButton(bool enable);
 
 
    void enableButtonsHandlingResults(bool enable);
 
 
    void sendParameters(cParameters parameters);
 
 
    void reportSpectra();
 
 
    void setGraph(string s);
 
 
private slots:
 
    void stopComputation();
 
    void graphReaderFinished();
 
};
 
 
#endif