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

Question

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

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

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

File locks are held on behalf of the entire Java virtual machine. They are not suitable for controlling access to a file by multiple threads within the same virtual machine.

果然，阻塞调用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 的嵌入方式，有两种可能性:

1. 如果代码在 Rhino shell 中执行，请使用 sync(f,lock) function 将函数转换为在第二个参数或 this 上同步的函数如果第二个参数不存在，则为其调用的对象。 (早期版本仅具有单参数方法，因此除非您的第三方应用程序使用最新版本，否则您可能需要使用该版本或自行推出；请参见下文。)

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

问题可能是您尝试同步的对象不是跨上下文共享的，而是通过嵌入或其他东西多次创建的。如果是这样，您可能需要使用某种黑客手段，特别是如果您无法控制嵌入。如果您无法控制嵌入，则可以使用某种虚拟机全局对象进行同步，例如 Runtime.getRuntime()或其他东西(我想不出任何我立即知道的单一对象，但我怀疑其中有几个具有像 Runtime 这样的单一 API 的对象。)

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