Sasapea's Lab

【タスク休止管理クラス】

タイムアウト機能をサポートしたタスク休止管理クラス。ＧＰＩＯ、セマフォ、ミューテックス・クラスが継承している。

【ソース・コード】

/*
  wait.h - Wait Base Class

  Copyright (c) 2021 Sasapea's Lab. All right reserved.

  This library is free software; you can redistribute it and/or
  modify it under the terms of the GNU Lesser General Public
  License as published by the Free Software Foundation; either
  version 2.1 of the License, or (at your option) any later version.

  This library 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
  Lesser General Public License for more details.

  You should have received a copy of the GNU Lesser General
  Public License along with this library; if not, write to the
  Free Software Foundation, Inc., 59 Temple Place, Suite 330,
  Boston, MA  02111-1307  USA
*/
#ifndef __WAIT_H
#define __WAIT_H

#include <stdint.h>
#include <stdbool.h>
#include <util/atomic.h>

class Wait: protected Timer
{
  private:

    static bool remove_match(TASK_T *task, uint8_t val)
    {
      wakeup(task, val);
      return true;
    }

  protected:

    DEQUE(TASK_T, event) _queue;

    virtual ~Wait(void)
    {
      ATOMIC_BLOCK(ATOMIC_RESTORESTATE)
        _queue.removeMatch<uint8_t>(remove_match, WAIT_TIMEOUT);
    }

    void timeout(TASK_T *task) override
    {
      _queue.remove(task);      
    }

    static void wakeup(TASK_T *task, uint8_t wcode)
    {
      task->wcode = wcode;
      Timer::cansel(task);
      Task::enqueue(task);
    }

    bool wakeup(uint8_t wcode = WAIT_OBJECT)
    {
      TASK_T *task = _queue.dequeue();
      if (task)
      {
        wakeup(task, wcode);
        Task::switching();
        return true;
      }
      return false;
    }

    uint8_t sleep(int32_t timeout, uint8_t mode = 0)
    {
      TASK_T *task = Task::dequeue();
      if (task)
      {
        task->wcode = mode;
        _queue.enqueue(task);
        Timer::setup(task, timeout, this);
        Task::switching();
        return task->wcode;
      }
      return WAIT_TIMEOUT;
    }
};

#endif

wait.h - Wait Base Class

This library is free software; you can redistribute it and/or

modify it under the terms of the GNU Lesser General Public

License as published by the Free Software Foundation; either

version 2.1 of the License, or (at your option) any later version.

This library 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

Lesser General Public License for more details.

You should have received a copy of the GNU Lesser General

Public License along with this library; if not, write to the

Free Software Foundation, Inc., 59 Temple Place, Suite 330,

Boston, MA 02111-1307 USA

#ifndef __WAIT_H

#define __WAIT_H

#include <stdint.h>

#include <stdbool.h>

#include <util/atomic.h>

class Wait: protected Timer

{

private:

static bool remove_match(TASK_T *task, uint8_t val)

{

wakeup(task, val);

return true;

}

protected:

DEQUE(TASK_T, event) _queue;

virtual ~Wait(void)

{

ATOMIC_BLOCK(ATOMIC_RESTORESTATE)

_queue.removeMatch<uint8_t>(remove_match, WAIT_TIMEOUT);

}

void timeout(TASK_T *task) override

{

_queue.remove(task);

}

static void wakeup(TASK_T *task, uint8_t wcode)

{

task->wcode = wcode;

Timer::cansel(task);

Task::enqueue(task);

}

bool wakeup(uint8_t wcode = WAIT_OBJECT)

{

TASK_T *task = _queue.dequeue();

if (task)

{

wakeup(task, wcode);

Task::switching();

return true;

}

return false;

}

uint8_t sleep(int32_t timeout, uint8_t mode = 0)

{

TASK_T *task = Task::dequeue();

if (task)

{

task->wcode = mode;

_queue.enqueue(task);

Timer::setup(task, timeout, this);

Task::switching();

return task->wcode;

}

return WAIT_TIMEOUT;

}

};

#endif

投稿

理想のＲＴＯＳを自作する (6)