nEJ*_*EJC 10 java multithreading jython thread-safety
我正在构建一个Java框架,它将监听事件,然后在Jython中处理它们.不同的事件类型将被发送到不同的脚本.
由于在调用PythonInterpreter.exec()时jython需要相当长的时间来编译脚本,因此我必须预编译脚本.我是按照以下方式做的:
// initialize the script as string (would load it from file in final version)
String script = "print 'foo'";
// get the compiled code object
PyCode compiled = org.python.core.__builtin__.compile( script, "<>", "exec" );
Run Code Online (Sandbox Code Playgroud)
PyCode编译对象将被推送到存储库并在事件进入时使用
PythonInterpreter pi = new PythonInterpreter();
pi.set( "variable_1", "value_1");
pi.set( "variable_x", "value_x");
pi.exec( compiled );
Run Code Online (Sandbox Code Playgroud)
现在,对于我的难题 - 可能会发生某些类型的多个事件同时发生 - 因此同时运行多个脚本实例.
几乎所有脚本都可能保持短暂 - 最多100行,没有循环.数字和频率是完全随机的(用户生成的事件),每个事件类型可以是每秒0到大约200.
最好的方法是什么?我正在寻找一些可能性:
2号和3号的组合可能是最好的 - 创建动态池大小?
那么,有什么想法吗?;)
遗憾的是PyCode实例不是不可变的(类中有很多公共成员)。
您可以使用以下代码预编译可重用的脚本:
// TODO: generate this name
final String name = "X";
byte[] scriptBytes = PyString.to_bytes(script);
CompilerFlags flags = Py.getCompilerFlags();
ByteArrayOutputStream ostream = new ByteArrayOutputStream();
Module.compile(parser.parse(new ByteArrayInputStream(scriptBytes), "exec",
"<>", flags), ostream, name, "<>", false, false, false, flags);
byte[] buffer = ostream.toByteArray();
Class<PyRunnable> clazz = BytecodeLoader.makeClass(name, null, buffer);
final Constructor<PyRunnable> constructor = clazz
.getConstructor(new Class[] { String.class });
Run Code Online (Sandbox Code Playgroud)
然后,您可以在需要时使用构造函数为脚本生成 PyCode 实例:
PyRunnable r = constructor.newInstance(name);
PyCode pc = r.getMain();
Run Code Online (Sandbox Code Playgroud)
我首先承认这不是一个好的做事方式,并且可能充分说明了我对 Jython 的缺乏经验。然而,它比每次编译都要快得多。该代码可以在 Jython 2.2.1 下运行,但无法在 Jython 2.5 下编译(您的也不会)。