Thread.hh

Go to the documentation of this file.

#ifndef COSA_NUCLEO_THREAD_HH
#define COSA_NUCLEO_THREAD_HH

#include "Cosa/Types.h"
#include "Cosa/Linkage.hh"
#include <setjmp.h>

namespace Nucleo {

class Thread : public Link {
public:
  static Thread* running()
  {
    return (s_running);
  }

  static void begin(Thread* thread = NULL, size_t size = 0);

  virtual void run();

  void resume(Thread* thread);

  void yield()
    __attribute__((always_inline))
  {
    Thread* thread = (Thread*) succ();
    if (thread == this) thread = &s_main;
    resume(thread);
  }

  void delay(uint32_t ms);

  void enqueue(Head* queue, Thread* thread = NULL);

  void dequeue(Head* queue, bool flag = true);

  static void service();

protected:
  static const size_t MAIN_STACK_MAX = 64;

  static Head s_delayed;

  static Thread s_main;

  static Thread* s_running;

  static size_t s_top;

  jmp_buf m_context;

  uint32_t m_expires;

  void init(void* stack);

  friend class Semaphore;
};

};
#endif