forked from farmboy0/luaj
-
Notifications
You must be signed in to change notification settings - Fork 0
/
SampleMultiThreaded.java
59 lines (53 loc) · 1.88 KB
/
SampleMultiThreaded.java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
import java.io.IOException;
import org.luaj.vm2.Globals;
import org.luaj.vm2.lib.jse.JsePlatform;
/** Simple toy program illustrating how to run Luaj in multiple threads.
*
* <p>By creating separate Globals in each thread, scripts can be run in each thread.
*
* <p>However note the following:
* <ul><li>type-related metatables such as LuaNumber.s_metatable are shared by all threads, so are not thread-safe.
* </li><li>creating additional threads within a Java element called by lua could result in shared access to globals.
* </li></ul>
*
* This can be used when all the scripts running can be trusted.
* For examples of how to sandbox scripts in protect against rogue scripts,
* see examples/jse/SampLeSandboxed.java.
*/
public class SampleMultiThreaded {
static class Runner implements Runnable {
final String script1, script2;
Runner(String script1, String script2) {
this.script1 = script1;
this.script2 = script2;
}
public void run() {
try {
// Each thread must have its own Globals.
Globals g = JsePlatform.standardGlobals();
// Once a Globals is created, it can and should be reused
// within the same thread.
g.loadfile(script1).call();
g.loadfile(script2).call();
} catch ( Exception e ) {
e.printStackTrace();
}
}
}
public static void main(final String[] args) throws IOException {
final String script1 = args.length > 0? args[0]: "test/lua/perf/nsieve.lua";
final String script2 = args.length > 1? args[1]: "test/lua/perf/binarytrees.lua";
try {
Thread[] thread = new Thread[10];
for (int i = 0; i < thread.length; ++i)
thread[i] = new Thread(new Runner(script1, script2),"Runner-"+i);
for (int i = 0; i < thread.length; ++i)
thread[i].start();
for (int i = 0; i < thread.length; ++i)
thread[i].join();
System.out.println("done");
} catch ( Exception e ) {
e.printStackTrace();
}
}
}