70 lines
3.0 KiB
C++
70 lines
3.0 KiB
C++
/*****************************************************************************
|
|
* *
|
|
* T H R E A D *
|
|
* *
|
|
*---------------------------------------------------------------------------*
|
|
* Beschreibung: Implementierung eines kooperativen Thread-Konzepts. *
|
|
* Thread-Objekte werden vom Scheduler in einer verketteten *
|
|
* Liste 'readylist' verwaltet. *
|
|
* *
|
|
* Im Konstruktor wird der initialie Kontext des Threads *
|
|
* eingerichtet. Mit 'start' wird ein Thread aktiviert. *
|
|
* Die CPU sollte mit 'yield' freiwillig abgegeben werden. *
|
|
* Um bei einem Threadwechsel den Kontext sichern zu *
|
|
* koennen, enthaelt jedes Threadobjekt eine Struktur *
|
|
* ThreadState, in dem die Werte der nicht-fluechtigen *
|
|
* Register gesichert werden koennen. *
|
|
* *
|
|
* Zusaetzlich zum vorhandenen freiwilligen Umschalten der *
|
|
* CPU mit 'Thread_switch' gibt es nun ein forciertes Um- *
|
|
* durch den Zeitgeber-Interrupt ausgeloest wird und in *
|
|
* Assembler in startup.asm implementiert ist. Fuer das *
|
|
* Zusammenspiel mit dem Scheduler ist die Methode *
|
|
* 'prepare_preemption' in Scheduler.cc wichtig. *
|
|
* *
|
|
* Autor: Michael, Schoettner, HHU, 16.12.2016 *
|
|
*****************************************************************************/
|
|
|
|
#ifndef Thread_include__
|
|
#define Thread_include__
|
|
|
|
#include "user/lib/utility/Logger.h"
|
|
|
|
class Thread {
|
|
private:
|
|
unsigned int* stack;
|
|
unsigned int esp;
|
|
|
|
protected:
|
|
Thread(char* name);
|
|
|
|
NamedLogger log;
|
|
|
|
bool running = true; // For soft exit, if thread uses infinite loop inside run(), use this as condition
|
|
char* name; // For logging
|
|
unsigned int tid; // Thread-ID (wird im Konstruktor vergeben)
|
|
friend class Scheduler; // Scheduler can access tid
|
|
|
|
public:
|
|
Thread(const Thread& copy) = delete; // Verhindere Kopieren
|
|
|
|
virtual ~Thread() {
|
|
log.info() << "Uninitialized thread, ID: " << dec << tid << " (" << name << ")" << endl;
|
|
delete[] stack;
|
|
}
|
|
|
|
// Thread aktivieren
|
|
void start() const;
|
|
|
|
// Umschalten auf Thread 'next'
|
|
void switchTo(Thread& next);
|
|
|
|
// Ask thread to terminate itself
|
|
void suicide() { running = false; }
|
|
|
|
// Methode des Threads, muss in Sub-Klasse implementiert werden
|
|
virtual void run() = 0;
|
|
};
|
|
|
|
#endif
|