concur/task_pool.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.task_pool
#
# -----------------------------------------------------------------------

# simple, dynamically sized task runner
#
public task_pool : effect
is

  thrds := concur.atomic (list concur.Thread) .new nil


  # submit a task to the thread pool
  #
  # returns false if the pool is already shutting down
  #
  public submit(P type : time.Period, t realtime.task P) unit ! atomic_access =>

    nt := concur.threads.env.spawn ()->
      now := time.nano.env.read
      end_of_time := time.instant u64.max
      _ := time.nano.env.run_periodic now t.period end_of_time t.code

    thrds.write (list nt thrds)


  # stop accepting jobs,
  # notify all threads to wake up,
  # wait for all threads to finish
  #
  public redef finally unit ! atomic_access =>

    # wait for all threads to finish
    thrds.read.for_each t->
      t.join