concur/thread.fz
# This file is part of the Fuzion language implementation.
#
# The Fuzion language implementation is free software: you can redistribute it
# and/or modify it under the terms of the GNU General Public License as published
# by the Free Software Foundation, version 3 of the License.
#
# The Fuzion language implementation 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 General Public
# License for more details.
#
# You should have received a copy of the GNU General Public License along with The
# Fuzion language implementation. If not, see <https://www.gnu.org/licenses/>.
# -----------------------------------------------------------------------
#
# Tokiwa Software GmbH, Germany
#
# Source code of Fuzion standard library feature concur.thread
#
# Author: Fridtjof Siebert (siebert@tokiwa.software)
#
# -----------------------------------------------------------------------
# thread -- effect that provides concurrent thread
#
public thread (
# the handler this effect uses to spawn threads
p Thread_Handler
) : simple_effect
is
# type for a spawned thread
#
private:public spawned(private id i64) is
# wait for this thread to finish execution
#
# NYI it should be made impossible to call this more than once
#
public join =>
fuzion.sys.thread.join0 id
_ := thread p
# spawn a new thread
#
public spawn(code ()->unit) =>
st := p.spawn code
_ := thread p
st
type.install_default =>
(concur.thread default_thread).default
# default thread handler
#
type.default_thread : concur.Thread_Handler is
# spawn a new thread using given code
#
spawn(code ()->unit) => concur.thread.spawned (fuzion.sys.thread.spawn code)
# thread with no argument returns thread.env, i.e., the currently installed
# source of thread concurrency.
#
public thread =>
thread.install_default
thread.env
# Thread_Provider -- abstract source of concurrency
#
private:public Thread_Handler ref is
# spawn a new thread using given code
#
spawn(code ()->unit) concur.thread.spawned => abstract
last changed: 2024-03-07