多个 Rhino (java) 线程操作同一个文件

Question

我正在使用嵌入式 Rhino 的第 3 方应用程序中编写一段 javascript (ecmascript)。应用程序可能会启动多个 Java 线程来同时处理数据。似乎每个 Java 线程都启动了自己的嵌入式 Rhino 上下文，然后运行我的脚本。

我的脚本的目的是从应用程序接收数据并使用它来维护特定文件的内容。我需要一个故障安全解决方案来处理脚本中的并发。

到目前为止，我想出的是调用java并使用java.nio.channels.FileLock。但是，文档here 指出：

代表整个 Java 虚拟机持有文件锁。它们不适用于控制同一虚拟机内的多个线程对文件的访问。

果然，阻塞调用FileChannel.lock()没有阻塞反而抛出异常，导致如下丑陋的代码：

var count = 0;
while ( count < 100 )
{
    try 
    {
        var rFile = new java.io.RandomAccessFile(this.mapFile, "rw");
        var lock = rFile.getChannel().lock();
        try
        {
            // Here I do whatever the script needs to do with the file
        }
        finally
        {
            lock.release();
        }
        rFile.close();
        break;
    } catch (ex) {
        // This is reached whenever another instance has a lock
        count++;
        java.lang.Thread.sleep( 10 );
    }       
}

问：如何安全可靠地解决这个问题？

我看到过有关 Rhino sync() 与 Java synchronized 相似的帖子，但这似乎在 Rhino 的多个实例之间不起作用。

更新

我尝试过使用Synchronizer 和org.mozilla.javascript.tools.shell.Global 作为模板的建议：

function synchronize( fn, obj )
{
    return new Packages.org.mozilla.javascript.Synchronizer(fn).call(obj);
}

接下来，我使用这个函数如下：

    var mapFile = new java.io.File(mapFilePath);
    // MapWriter is a js object
    var writer = new MapWriter( mapFile, tempMap );
    var on = Packages.java.lang.Class.forName("java.lang.Object");
    // Call the writer's update function synchronized
    synchronize( function() { writer.update() } , on );

但是我看到两个线程同时进入update() 函数。我的代码有什么问题？

Answer 1

根据 Rhino 的嵌入方式，有两种可能：

1234563缺席。 （早期版本只有一个参数方法，因此除非您的第三方应用程序使用最新版本，否则您可能需要使用该版本或推出自己的版本；见下文。）

1. 如果应用程序不使用 Rhino shell，而是使用不包含并发工具的自定义嵌入，您需要推出自己的版本。 sync 的源代码是一个很好的起点（参见 Global 和 Synchronizer 的源代码；您应该能够像 Global 使用它一样开箱即用地使用 Synchronizer）。

问题可能是您尝试同步的对象不是跨上下文共享的，而是由嵌入或其他东西多次创建的。如果是这样，您可能需要使用某种 hack，尤其是在您无法控制嵌入的情况下。如果您无法控制嵌入，则可以使用某种 VM 全局对象进行同步，例如 Runtime.getRuntime() 或其他东西（我想不出我立即知道的任何单个对象，但我怀疑有几个那些使用像 Runtime 这样的单例 API 的人。）

另一个需要同步的对象是 Packages.java.lang.Class.forName("java.lang.Object")，它应该在所有上下文中引用同一个对象（Object 类），除非嵌入的类加载器设置非常不寻常。