Method run

src/main/java/field/app/ThreadSync.java:222–289

(String tag, Supplier<K> in, Consumer<V> out, Callable<V> r, Consumer<Throwable> h)

    public <K, V> Fiber<K, V> run(String tag, Supplier<K> in, Consumer<V> out, Callable<V> r, Consumer<Throwable> h) throws InterruptedException {
        Fiber<K, V> f = new Fiber<>();
        live.add(f);
        f.debugDescription = tag;
        f.handler = h;
        f.in = in;
        f.input.put(in.get());
        f.out = out;
        threadingModel.set(this);
        ClassLoader loader = Thread.currentThread()
                .getContextClassLoader();

        f.runner = executor.submit(() -> {

            try {
                Thread.currentThread()
                        .setName("" + f.debugDescription);
                Thread.currentThread()
                        .setContextClassLoader(loader);

                fiber.set(f);
                f.input.take();

                Object a = r.call();
                if (a == null) f.output.put(NULL);
                else f.output.put(a == null ? NULL : a);

                return a;
            } catch (Stop s) {
                f.runner.cancel(true);
                f.output.put(NULL);
                return null;
            } catch (Throwable t) {
                f.exception = t;
                f.runner.cancel(true);
                System.err.println(" -- caught throwable ");
                f.output.put(NULL);
                t.printStackTrace();
                System.err.println(" -- rethrowing <" + f.output.peek() + "> -> " + f.handler);
                if (f.output.peek() == null) f.output.put(NULL);
                throw t;
            } finally {
                // need to unwide sub fibers to allow recursion.
                if (models.containsKey(Thread.currentThread())) {
                    ThreadSync m = ThreadSync.get();
                    m.shutdown();
                }
                fiber.set(null);
            }
        });
        currentFiber = f;
        try {

            Object o = debugTake(f);
            if (f.runner.isDone()) live.remove(this);
            if (o == NULL) o = null;
            out.accept((V) o);
            f.lastReturn = o == NULL ? null : (V) o;