Улучшенная функция thread

Author: aNNiMON

program.own

@@ -111,4 +111,9 @@ println typeof({})
 println typeof(add)
 
 println typeof(number("1"))
-println typeof(string(1))
+println typeof(string(1))
+
+thread(::inthread)
+def inthread() = echo("this is a thread")
+thread(def (str) { println str }, "this is a thread with arguments")
+

src/com/annimon/ownlang/lib/modules/functions/std_thread.java

@@ -1,20 +1,34 @@
 package com.annimon.ownlang.lib.modules.functions;
 
 import com.annimon.ownlang.lib.Function;
+import com.annimon.ownlang.lib.FunctionValue;
 import com.annimon.ownlang.lib.Functions;
 import com.annimon.ownlang.lib.NumberValue;
+import com.annimon.ownlang.lib.Types;
 import com.annimon.ownlang.lib.Value;
 
 public final class std_thread implements Function {
 
     @Override
     public Value execute(Value... args) {
-        if (args.length == 1) {
-            // Создаём новый поток по имени функции
-            new Thread(() -> {
-                Functions.get(args[0].asString()).execute();
-            }).start();
+        // Создаём новый поток и передаём параметры, если есть.
+        // Функция может передаваться как напрямую, так и по имени
+        if (args.length == 0) throw new RuntimeException("At least one arg expected");
+        
+        Function body;
+        if (args[0].type() == Types.FUNCTION) {
+            body = ((FunctionValue) args[0]).getValue();
+        } else {
+            body = Functions.get(args[0].asString());
         }
+        
+        // Сдвигаем аргументы
+        final Value[] params = new Value[args.length - 1];
+        if (params.length > 0) {
+            System.arraycopy(args, 1, params, 0, params.length);
+        }
+        
+        new Thread(() -> body.execute(params)).start();
         return NumberValue.ZERO;
     }
 }