0

我正在尝试使用 mongo 1.8.0 模拟 mongo 写锁,但无法看到正确的预期结果。

我在同一台服务器上的两个不同数据库中创建了两个 mongo 集合。我创建了一个 DBObject 数组并将它们插入到两个集合中。使用两个线程同时触发批量插入。我还跟踪调用 DBCollection.insert(DBObject arr, WriteConcern.SAFE) 之前和之后的时间。

尽管使用了不同的对象大小和数组大小,但我总是发现插入两个数据库所花费的时间有点接近。我希望一个线程首先写入阻塞另一个线程,导致两个线程之间花费的时间显着不同。我在这里缺少什么吗?

class BenchTest {

public static void main() {

    Mongo m = new Mongo(host,port);
    DBCollection coll1 = m.getDB("db0").getColl("coll0");
    DBCollection coll2 = m.getDB("db1").getColl("coll0");

    Thread t1 = new WriteThread();
    t1.setCollection(coll1);
    Thread t2 = new WriteThread();
    t2.setCollection(coll2);

    t1.run();
    t2.run();

}

}


   class WriteThread extends Thread {

    DBCollection coll; 

    public void setCollection (DBCollection coll) {
        this.coll = coll;
    }

    long startTime = System.currentTimeMillis();
    coll.insert( (DBObject1, DBObject2, …, DBObjectn), WriteConcern.SAFE);
    long endTime = System.currentTimeMillis();

    System.out.println ("Time taken = "+(endTime-startTime));

}
4

1 回答 1

2

为什么不直接使用fsync & lock来模拟“写锁”呢?

很难模拟“写锁”,因为它基本上不会挂起,它只存在很短的时间。此处概述的版本(1.8、2.0 和 2.2)有许多变化(以免重复我自己)。

这是一篇关于其他人对“写锁”进行类似测试的非常好的博客文章。

于 2012-08-23T14:45:41.163 回答