首页
学习
活动
专区
圈层
工具
发布
社区首页 >问答首页 >试图使Nashorn线程安全

试图使Nashorn线程安全
EN

Stack Overflow用户
提问于 2016-02-22 20:32:56
回答 2查看 1.2K关注 0票数 3

我最近一直在为这出戏工作!框架和Nashorn试图呈现一个Redux应用程序。最初,我在ThreadPoolExecutor中实现了多个Nashorn引擎,并在运行engine.eval()时使用了期货。性能很糟糕,我想是因为高I/O和我所使用的阻塞未来。

在对游戏更加熟悉之后!以及他们的异步/承诺模式,我尝试用一个ScriptEngine重新开始;按照https://stackoverflow.com/a/30159424/5956783,脚本引擎本身是线程安全的,但是绑定并不安全。下面是完整的类:

代码语言:javascript
复制
package services;

import akka.actor.ActorSystem;

import play.libs.F;
import scala.concurrent.ExecutionContext;

import java.io.FileReader;


import javax.inject.Inject;
import javax.inject.Singleton;
import javax.script.*;

@Singleton
public class NashornEngine extends JSEngineAbstract {

    private NashornThread engine;
    private final ActorSystem actorSystem;


    protected class NashornThread {
        private ScriptEngine engine;
        private final ExecutionContext executionContext = actorSystem.dispatchers().lookup("js-engine-executor");
        private CompiledScript compiledScript;


        public NashornThread() {
            try {
                String dir = System.getProperty("user.dir");
                this.engine = new ScriptEngineManager(null).getEngineByName("nashorn");
                this.compiledScript = ((Compilable) this.engine).compile(new FileReader(dir + "/public/javascripts/bundle.js"));
            } catch (Exception e) {
                System.out.println(e.getMessage());
            }
        }

        public ScriptEngine getEngine() {
            return engine;
        }

        public F.Promise<String> getContent(String path, String globalCode) {
            return F.Promise.promise(() -> this.executeMethod(path, globalCode), this.executionContext);
        }

        private String executeMethod(String path, String json) throws ScriptException {
            Bindings newBinding = engine.createBindings();
            try {
                this.compiledScript.eval(newBinding);
                getEngine().setBindings(newBinding, ScriptContext.ENGINE_SCOPE);
                getEngine().eval("var global = this;");
                getEngine().eval("var console = {log: print, error: print, warn: print};");
                String result = getEngine().eval("App.renderApp('" + path + "', " + json + ")").toString();

                return result;
            } catch(Exception e) {
                e.printStackTrace();
                return null;
            }
        }
    }


    @Inject
    public NashornEngine(ActorSystem actorSystem) {
        this.actorSystem = actorSystem;
        this.engine = new NashornThread();
    }

    @Override
    public F.Promise<String> getContent(String path, String globalCode) {
        try {
            F.Promise<String> result = engine.getContent(path, globalCode);

            return result.map((String r) -> r);
        } catch (Exception e) {
            e.printStackTrace();
            return null;
        }
    }
}

我的JavaScript应用程序导出一个App对象,其方法是renderApp(path, state)可视。这确实有效,但只有16次(是的,总是16次)。从迭代17开始,我得到以下异常和伴随的堆栈跟踪:

代码语言:javascript
复制
java.lang.ClassCastException: jdk.nashorn.internal.objects.NativeRegExpExecResult cannot be cast to jdk.nashorn.internal.objects.NativeArray
    at jdk.nashorn.internal.objects.NativeArray.getContinuousArrayDataCCE(NativeArray.java:1900)
    at jdk.nashorn.internal.objects.NativeArray.popObject(NativeArray.java:937)
    at jdk.nashorn.internal.runtime.ScriptFunctionData.invoke(ScriptFunctionData.java:660)
    at jdk.nashorn.internal.runtime.ScriptFunction.invoke(ScriptFunction.java:228)
    at jdk.nashorn.internal.runtime.ScriptRuntime.apply(ScriptRuntime.java:393)
    at jdk.nashorn.internal.scripts.Script$Recompilation$23589$782286AA$\^eval\_.L:22918$L:22920$matchPattern(<eval>:23049)
    at jdk.nashorn.internal.scripts.Script$Recompilation$23588$816752AAAAAA$\^eval\_.L:24077$L:24079$matchRouteDeep(<eval>:24168)
    at jdk.nashorn.internal.scripts.Script$Recompilation$23587$820262DAA$\^eval\_.L:24077$L:24079$matchRoutes$L:24252$L:24253(<eval>:24254)
    at jdk.nashorn.internal.scripts.Script$Recompilation$23586$809060$\^eval\_.L:23848$loopAsync$next(<eval>:23869)
    at jdk.nashorn.internal.scripts.Script$Recompilation$23584$808906AAA$\^eval\_.L:23848$loopAsync(<eval>:23875)
    at jdk.nashorn.internal.scripts.Script$Recompilation$23583$820189$\^eval\_.L:24077$L:24079$matchRoutes$L:24252(<eval>:24253)
    at jdk.nashorn.internal.scripts.Script$Recompilation$23582$819862AAA$\^eval\_.L:24077$L:24079$matchRoutes(<eval>:24252)
    at jdk.nashorn.internal.scripts.Script$Recompilation$23580$789440AA$\^eval\_.L:23151$L:23153$useRoutes$L:23209$match(<eval>:23239)
    at jdk.nashorn.internal.scripts.Script$Recompilation$23518$847004AA$\^eval\_.L:25026$L:25028$match(<eval>:25084)
    at jdk.nashorn.internal.scripts.Script$Recompilation$23468$3872AA$\^eval\_.L:53$renderApp(<eval>:147)
    at jdk.nashorn.internal.scripts.Script$23467$\^eval\_.:program(<eval>:1)
    at jdk.nashorn.internal.runtime.ScriptFunctionData.invoke(ScriptFunctionData.java:640)
    at jdk.nashorn.internal.runtime.ScriptFunction.invoke(ScriptFunction.java:228)
    at jdk.nashorn.internal.runtime.ScriptRuntime.apply(ScriptRuntime.java:393)
    at jdk.nashorn.api.scripting.NashornScriptEngine.evalImpl(NashornScriptEngine.java:446)
    at jdk.nashorn.api.scripting.NashornScriptEngine.evalImpl(NashornScriptEngine.java:403)
    at jdk.nashorn.api.scripting.NashornScriptEngine.evalImpl(NashornScriptEngine.java:399)
    at jdk.nashorn.api.scripting.NashornScriptEngine.eval(NashornScriptEngine.java:155)
    at javax.script.AbstractScriptEngine.eval(AbstractScriptEngine.java:264)
    at services.NashornEngine$NashornThread.executeMethod(NashornEngine.java:62)
    at services.NashornEngine$NashornThread.lambda$getContent$0(NashornEngine.java:48)
    at play.core.j.FPromiseHelper$$anonfun$promise$2.apply(FPromiseHelper.scala:36)
    at scala.concurrent.impl.Future$PromiseCompletingRunnable.liftedTree1$1(Future.scala:24)
    at scala.concurrent.impl.Future$PromiseCompletingRunnable.run(Future.scala:24)
    at akka.dispatch.TaskInvocation.run(AbstractDispatcher.scala:40)
    at akka.dispatch.ForkJoinExecutorConfigurator$AkkaForkJoinTask.exec(AbstractDispatcher.scala:397)
    at scala.concurrent.forkjoin.ForkJoinTask.doExec(ForkJoinTask.java:260)
    at scala.concurrent.forkjoin.ForkJoinPool$WorkQueue.runTask(ForkJoinPool.java:1339)
    at scala.concurrent.forkjoin.ForkJoinPool.runWorker(ForkJoinPool.java:1979)
    at scala.concurrent.forkjoin.ForkJoinWorkerThread.run(ForkJoinWorkerThread.java:107)

我的印象是,用编译后的脚本创建一个新绑定将被视为引擎的新特性,但情况似乎并非如此。如果有什么,我在这里做错了什么?

我也尝试过使用Invocable来调用App对象上的方法,但这并没有什么区别。

编辑I是在一个8核心机器的超线程,所以这可能解释之前的16次成功尝试之前,第17次尝试失败。此外,我还更新了executeMethod方法如下:

代码语言:javascript
复制
private String executeMethod(String path, String json) throws ScriptException {
            Bindings newBinding = engine.createBindings();
            try {
                this.compiledScript.eval(newBinding);
                getEngine().eval("var global = this;", newBinding);
                getEngine().eval("var console = {log: print, error: print, warn: print};", newBinding);
                Object app = getEngine().eval("App", newBinding);
                Invocable invEngine = (Invocable) getEngine();
                String result = invEngine.invokeMethod(app, "renderApp", path, json).toString();
//              String result = getEngine().eval("App.renderApp('" + path + "', " + json + ")", newBinding).toString();

                return result;
            } catch(Exception e) {
                e.printStackTrace();
                return null;
            }
        }
EN

回答 2

Stack Overflow用户

回答已采纳

发布于 2016-02-23 15:16:41

不幸的是你在纳什霍恩撞上了一个错误。好消息是它已经被修复了,并且这个补丁在当前的早期访问版本中可用。

票数 1
EN

Stack Overflow用户

发布于 2016-02-24 15:02:32

更新到Nashorn的最新版本,即Java1.8u 76修复了这个问题。

票数 2
EN
页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持
原文链接:

https://stackoverflow.com/questions/35563250

复制
相关文章

相似问题

领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档