如何避免两个不同的线程从数据库读取相同的行(Hibernate和Oracle 10g)
假设我有两个不同的线程,T1 和 T2,并发访问同一数据库并从同一表中提取数据。
现在,在线程启动时,我需要从表中获取数据并将行存储到集合中,然后我将使用该集合在其他地方执行一些工作。我不希望两个线程能够处理相同的数据,因为这会导致重复(和长)的工作。更具体地说,这是一个企业应用程序,需要在启动时加载一些记录并将其存储在集合中以执行一些额外的工作。问题在于,在群集环境中,这可能会导致两个不同的实例加载相同的数据,因此可能会重复工作。因此,我希望单个实例仅加载一次行。
如何避免这种情况?
我目前正在使用Hibernate和Oracle 10g。这些是我到目前为止的解决方案:
以编程方式锁定行。读取它的第一个将某些“锁定”列设置为 true,但如果第一个线程在未将行设置为“已处理”的情况下死亡,则很可能会发生死锁。
使用悲观锁定。我尝试使用LockMode.UPGRADE,但似乎没有帮助,因为我仍然能够同时从两个线程读取数据。
public List<MyObject> getAllNtfFromDb() { Session session = HibernateUtil.getOraclesessionfactory().openSession(); Query q = session.createQuery( "from MyObject n where n.state = 'NEW'"); List<MyObject> list = (List<MyObject>) q.list(); for (int i=0; i<list.size(); i++) session.lock(list.get(i), LockMode.UPGRADE); return list; }
还有其他提示吗?我做错了什么?
谢谢。