锁定问题：需要一些集思广益的建议

Question

我有服务器服务，如果满足某个条件，它会释放表数据库。看起来像这样

public static void autoUnloadDbTable(final Configuration conf) {
   final String mKey = getMapKey(conf);
   final Table table = TABLES.get(mKey);
   if (table != null) {
      dblock.getLock().lock();
      table.instance.dispose();
      TABLES.remove(mKey);.....(2)
   }
   //here release lock when done...
}

但是当上面的函数执行时，还有另一种操作可以横向运行

public Table getTableLocked(final Lock lock) throws FactFinderException {
   boolean loadTable = true;
   // Get the current table instance
   Table table = TABLES.get(mapKey);
   // .....(1)
   if (table != null) {
      //do something
   }

   if (loadTable) table = loadTableLocked(table);

   // lock the table, so the instance don't gets replaced
   if (lock != null) lock.lock();   
   return table.instance;
}

在 (1) 处，我需要放置一些东西，因为如果一个线程正在执行 (2) 处的代码，而另一个线程在线程 (2 ）已经有一个表对象，但由于（2）正在执行，所以它将删除表对象，然后（1）之外的所有内容都将没有正确的值......请有任何建议......？

Answer 1

您可能需要围绕表进行读/写锁定。在执行 TABLES.get(...) 来使用 table 中的内容之前获取读锁，并在执行 TABLES.get(...) 删除数据之前获取写锁。

另一种方法是每个表都有一个锁。在 TABLES.get(...) 获取表特定锁后，请确保该表仍在 TABLES 中，然后使用该锁执行操作。该表特定锁也可以是读/写锁，那么只有希望删除的代码才会获取写锁。当您尝试添加到表时，这会变得复杂，您需要聪明，并且可能对表使用 ConcurrentMap，并使用 putIfAbsent。

Answer 2

为什么不直接使用ConcurrentHashMap，它效率更高。

我认为您可以利用 ConcurrentHashMap 的锁定机制并删除您自己的锁定机制。所以
删除第 1 部分中的第一个：

public static void autoUnloadDbTable(final Configuration conf) {
    final String mKey = getMapKey(conf);
    final Table table = TABLES.remove(mKey);
    if (table != null) {
      table.instance.dispose();
    }
}

第 2 部分如下所示：

public Table getTableLocked(final Lock lock) throws FactFinderException {
    boolean loadTable = true;
    // Get the current table instance
    Table table = TABLES.get(mapKey);
                // .....(1)
    if (table != null) {
                   //do something
    }

    if (loadTable) table = loadTableLocked(table);
    return table.instance;
}

}

Answer 3

根据评论，您可以考虑包装您的表：

public class LockableTable {
 public Table table;
 public ReadWriteLock lock;
 public LockableTable(Table t){
   table = t;
   lock = ....
 }
}

然后，当您想要删除表时，您可以使用myLocakbleTable.lock.writeLock().lock()。其余时间，当您从表中读取数据时，您将使用 myLockableTable.lock.readLock().lock()