Merge branch 'threads' of https://github.com/gnembon/fabric-carpet into threads

This commit is contained in:
gnembon committed 2019-12-18 10:41:21 -04:00
commit ab3334e452
5 files changed
+26 -106

No files matched your search

@@ -1,6 +1,5 @@
package carpet.script.value;
import carpet.CarpetSettings;
import carpet.script.Context;
import carpet.script.Expression;
import carpet.script.Tokenizer;
@@ -10,46 +9,27 @@ import java.util.Collections;
import java.util.HashMap;
import java.util.Map;
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ConcurrentHashMap;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.Executors;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.function.Supplier;
public class ThreadValue extends Value
{
private CompletableFuture<Value> taskFuture;
//public static ThreadLocal<Boolean> joining = ThreadLocal.withInitial(() -> false);
public final static Map<Thread,Integer> waitingTreads = new ConcurrentHashMap<>();
public static Map<Thread,Integer> joinRequestedThreads = new ConcurrentHashMap<>();
private long id;
private final Object lock;
//private final boolean[] started;
private Thread executingThread;
private Supplier<Value>task;
private static long sequence = 0L;
private static final Map<Value,ThreadPoolExecutor> executorServices = new HashMap<>();
public ThreadValue(Value pool, FunctionValue function, Expression expr, Tokenizer.Token token, Context ctx)
{
id = sequence++;
lock = new Object();
executingThread = null;
//started = new boolean[]{false};
task = () ->
{
if (executingThread == null)
{
CarpetSettings.LOG.error("Setting the thread");
executingThread = Thread.currentThread();
return function.lazyEval(ctx, Context.NONE, expr, token, Collections.emptyList()).evalValue(ctx);
}
return null;
};
taskFuture = CompletableFuture.supplyAsync(
() -> { synchronized (lock) { CarpetSettings.LOG.error("getting in future"); Value ret = task.get(); CarpetSettings.LOG.error("gotten in future"); return ret;} },
executorServices.computeIfAbsent(pool, (v) -> (ThreadPoolExecutor)Executors.newCachedThreadPool())
() -> { synchronized (lock) {
return function.lazyEval(ctx, Context.NONE, expr, token, Collections.emptyList()).evalValue(ctx);
} },
executorServices.computeIfAbsent(pool, (v) -> (ThreadPoolExecutor)Executors.newCachedThreadPool())
);
Thread.yield();
}
@@ -68,45 +48,14 @@ public class ThreadValue extends Value
public Value join()
{
CarpetSettings.LOG.error("in join "+id);
if (executingThread == null)
{
CarpetSettings.LOG.error("not started "+id);
Value res;
waitingTreads.put(Thread.currentThread(), 1);
try
{
CarpetSettings.LOG.error(" getting result "+id);
res = task.get();
CarpetSettings.LOG.error(" result got "+id);
}
finally
{
waitingTreads.remove(Thread.currentThread());
}
taskFuture.complete(res);
return res;
}
try
{
synchronized (waitingTreads)
{
if (waitingTreads.containsKey(executingThread))
throw new InternalExpressionException("Cannot wait/join on world accessing thread");
waitingTreads.put(executingThread, 1);
}
CarpetSettings.LOG.error("getting future "+id);
return taskFuture.get();
}
catch (InterruptedException | ExecutionException e)
{
return Value.NULL;
}
finally
{
waitingTreads.remove(executingThread);
CarpetSettings.LOG.error(" future gotten "+id);
}
}
public boolean isFinished()
@@ -120,7 +69,6 @@ public class ThreadValue extends Value
{
if (!taskFuture.isDone())
{
executingThread = Thread.currentThread();
taskFuture.complete(Value.NULL);
}
}