library/platform/jvm/threads.factor

   1 ! :folding=indent:collapseFolds=1:
   2
   3 ! $Id$
   4 !
   5 ! Copyright (C) 2003 Slava Pestov.
   6 !
   7 ! Redistribution and use in source and binary forms, with or without
   8 ! modification, are permitted provided that the following conditions are met:
   9 !
  10 ! 1. Redistributions of source code must retain the above copyright notice,
  11 !    this list of conditions and the following disclaimer.
  12 !
  13 ! 2. Redistributions in binary form must reproduce the above copyright notice,
  14 !    this list of conditions and the following disclaimer in the documentation
  15 !    and/or other materials provided with the distribution.
  16 !
  17 ! THIS SOFTWARE IS PROVIDED ``AS IS'' AND ANY EXPRESS OR IMPLIED WARRANTIES,
  18 ! INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND
  19 ! FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE
  20 ! DEVELOPERS AND CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL,
  21 ! SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO,
  22 ! PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS;
  23 ! OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY,
  24 ! WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR
  25 ! OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF
  26 ! ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
  27
  28 IN: threads
  29
  30 USE: combinators
  31 USE: continuations
  32 USE: kernel
  33 USE: stack
  34
  35 : <thread> ( runnable -- thread )
  36     [ "java.lang.Runnable" ] "java.lang.Thread" jnew ;
  37
  38 : current-thread ( -- thread )
  39     [ ] "java.lang.Thread" "currentThread" jinvoke-static ;
  40
  41 : start-thread ( thread -- )
  42     [ ] "java.lang.Thread" "start" jinvoke ;
  43
  44 : clone-interpreter ( interp1 interp2 -- )
  45     #! Copy the state of interp1 into interp2.
  46     [ "factor.FactorInterpreter" ]
  47     "factor.FactorInterpreter"
  48     "init" jinvoke ;
  49
  50 : <interpreter> ( -- interpreter )
  51     #! Clone the current interpreter. Note that it will be
  52     #! pointing to exactly the same point of execution!
  53     [ ] "factor.FactorInterpreter" jnew ;
  54
  55 : fork* ( current new -- thread )
  56     dup <thread> [ clone-interpreter ] dip ; interpret-only
  57
  58 : fork ( -- ? )
  59     #! Spawn a new thread. In the original thread, push f.
  60     #! In the new thread, push t.
  61     interpreter <interpreter> fork* dup current-thread = [
  62         drop t
  63     ] [
  64         start-thread f
  65     ] ifte ; interpret-only
  66
  67 : in-thread ( quot -- )
  68     #! Execute a quotation in a new thread.
  69     fork [ call toplevel ] [ drop ] ifte ; interpret-only