stdlib/mutex.ajla

   1 {*
   2  * Copyright (C) 2024 Mikulas Patocka
   3  *
   4  * This file is part of Ajla.
   5  *
   6  * Ajla is free software: you can redistribute it and/or modify it under the
   7  * terms of the GNU General Public License as published by the Free Software
   8  * Foundation, either version 3 of the License, or (at your option) any later
   9  * version.
  10  *
  11  * Ajla is distributed in the hope that it will be useful, but WITHOUT ANY
  12  * WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR
  13  * A PARTICULAR PURPOSE. See the GNU General Public License for more details.
  14  *
  15  * You should have received a copy of the GNU General Public License along with
  16  * Ajla. If not, see <https://www.gnu.org/licenses/>.
  17  *}
  18
  19 unit mutex;
  20
  21 uses io;
  22
  23 type mutex;
  24
  25 fn mutex_new(w : world) : (world, mutex);
  26 fn mutex_lock(w : world, m : mutex) : world;
  27 fn mutex_unlock(w : world, m : mutex) : world;
  28
  29 implementation
  30
  31 uses msgqueue;
  32
  33 type mutex := msgqueue(unit_type);
  34
  35 fn mutex_new(implicit w : world) : (world, mutex)
  36 [
  37         var m := msgqueue_new(unit_type);
  38         mutex_unlock(m);
  39         return m;
  40 ]
  41
  42 fn mutex_lock(implicit w : world, m : mutex) : world
  43 [
  44         var tag, val := msgqueue_receive(m);
  45 ]
  46
  47 fn mutex_unlock(implicit w : world, m : mutex) : world
  48 [
  49         if msgqueue_is_nonempty(m) then
  50                 abort internal("unlocking unlocked mutex");
  51         msgqueue_send(m, 0, unit_value);
  52 ]