- android - RelativeLayout 背景可绘制重叠内容
- android - 如何链接 cpufeatures lib 以获取 native android 库?
- java - OnItemClickListener 不起作用,但 OnLongItemClickListener 在自定义 ListView 中起作用
- java - Android 文件转字符串
我有以下场景:
我正在使用一个主 servlet,它:
- 从数据库池中获取连接
- 将自动提交设置为 false
- 执行通过应用程序层的命令:如果全部成功,在“finally”语句中将自动提交设置为真,并关闭连接。否则如果发生异常,rollback()。
在我的数据库 (mysql/innoDb) 中,我有一个“历史”表,其中包含行列:
id(主键) |用户名|日期 |话题 |锁定
“锁定”列的默认值为“假”,它用作标记特定行是否锁定的标志。
每一行都特定于一个用户(正如你可以从用户名列中看到的那样)
所以回到场景:
-->Ulc1 发送命令以更新他从数据库中获取日期“D”和主题“T”的历史记录。
-->Ulc2 发送 same 命令以更新 来自数据库的相同 日期“D”和相同的历史记录 同一时间的主题“T”。
我想实现一个 mysql/innoDB 锁定系统,使任何到达的线程都能执行以下检查:
此行的“锁定”列是否为真?
这两种 mysql 锁定技术中的哪一种实际上允许第二个到达的线程读取锁定列的“更新”值来决定采取 wt 操作?
我应该使用 “更新” 或 “锁定共享模式”?
这个场景解释了我想要完成的事情:
- Ulc1 线程先到达:列“锁定”为假,将其设置为真并继续更新过程
- Ulc2 线程到达时 Ulc1 的事务仍在处理中,即使该行通过 innoDb 功能锁定,它也不必等待但实际上读取列锁定的"new"值是“真”,因此实际上不必等到 Ulc1 事务提交来读取“锁定”列的值(无论如何到那时该列的值已经被重置为 false)。
我对这两种锁定机制不是很有经验,到目前为止我的理解是 LOCK IN SHARE MODE 允许其他事务读取锁定的行,而 FOR UPDATE 甚至不允许读取。但是这个读取是否获得了更新的值?或者第二个到达的线程必须等待第一个线程提交然后读取值?
欢迎任何有关在这种情况下使用哪种锁定机制的建议。
此外,如果有更好的方法来“检查”行是否已被锁定(除了使用真/假列标志),请告诉我。
谢谢
解决方案
(Jdbc 伪代码示例基于@Darhazer 的 回答)
表:[ id(主键)|用户名|日期 |话题 |锁定]
connection.setautocommit(false);
//transaction-1
PreparedStatement ps1 = "Select locked from tableName for update where id="key" and locked=false);
ps1.executeQuery();
//transaction 2
PreparedStatement ps2 = "Update tableName set locked=true where id="key";
ps2.executeUpdate();
connection.setautocommit(true);// here we allow other transactions threads to see the new value
connection.setautocommit(false);
//transaction 3
PreparedStatement ps3 = "Update tableName set aField="Sthg" where id="key" And date="D" and topic="T";
ps3.executeUpdate();
// reset locked to false
PreparedStatement ps4 = "Update tableName set locked=false where id="key";
ps4.executeUpdate();
//commit
connection.setautocommit(true);
最佳答案
LOCK IN SHARE MODE 将允许第二个线程读取该值,但实际值将是查询(已提交读)或事务(可重复读取)开始之前的值(因为 MySQL 使用多版本控制; 并且第二个事务必须看到的内容由隔离级别定义)。因此,如果第一个事务在读取时未提交,则将读取旧值。
在您的场景中,最好有 1 个事务使用 select for update 锁定记录,另一个事务处理记录,在提交/回滚时,第三个事务解锁记录。
带有 select for update 的第二个线程事务将等待第一个线程完成,然后读取实际值并决定不继续其他事务,而是通知用户记录已锁定。
为避免死锁,请确保您正在使用唯一索引执行select for update
。
示例代码:
connection.setautocommit(false);
//transaction-1
PreparedStatement ps1 = "Select locked from tableName for update where id="key" and locked=false);
ps1.executeQuery();
//transaction 2
PreparedStatement ps2 = "Update tableName set locked=true where id="key";
ps2.executeUpdate();
connection.setautocommit(true); // here we allow other transactions / threads to see the new value
connection.setautocommit(false);
//transaction 3
PreparedStatement ps3 = "Update tableName set aField="Sthg" where id="key" And date="D" and topic="T";
ps3.executeUpdate();
// probably more queries
// reset locked to false
PreparedStatement ps4 = "Update tableName set locked=false where id="key";
ps4.executeUpdate();
//commit
connection.setautocommit(true);
关于mysql - "FOR UPDATE"v/s "LOCK IN SHARE MODE": Allow concurrent threads to read updated "state" value of locked row,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/9037345/
我想知道锁是如何在 Java 中实现的。在一些教程中,我发现它们应该使用 wait() 和 notify()/notifyAll() 以及一些 boolean 标志来实现(它可能比那复杂得多,但基本上
我正在开发一个多线程服务器,用于存储和读取来自数据库的信息。数据库是用 RocksDB 实现的。 我遇到的问题是,当我一次从多个线程访问数据库时,我得到了那个错误。 通常是说db在usign后没有被删
例如,这里有一些 linux 中的代码: void set_leds(int val) { int fd = open ("/dev/console", O_WRONLY); // argumen
关闭。这个问题需要更多focused .它目前不接受答案。 想改进这个问题吗? 更新问题,使其只关注一个问题 editing this post . 关闭 9 年前。 Improve this qu
考虑以下代码。为了防止IndexOutOfBoundsException打电话时 listIterator ,我们使用读取器锁来检索基于索引的 iteartor,并在对 stockCodes 进行写操
这个问题在这里已经有了答案: Java locking structure best pattern (2 个答案) 关闭 6 年前。 有什么区别: private Lock lock = new
是否可以在网页加载时检查 Scroll Lock、Num Lock 和 Caps Lock 的状态?我找到了使用 JavaScript 在按键后进行检查的方法,但这不是我要问的。 最佳答案 2019
是否可以在网页加载时检查 Scroll Lock、Num Lock 和 Caps Lock 的状态?我找到了使用 JavaScript 在按键后进行检查的方法,但这不是我要问的。 最佳答案 2019
在Ubuntu中安装某些东西时出现错误。我尝试了一些命令来杀死正在运行的进程,但仍然遇到相同的错误。 最佳答案 根据文章How to Fix “Waiting for cache lock: Coul
我们有一个gradle构建,它可以动态创建GradleBuild类型的多个任务,以与不同的客户端库版本一起运行以测试其兼容性。在Gradle4上可以正常工作,但是在移至Gradle5后,执行第一项任务
我在尝试运行在 vertica 数据库表上运行查询的客户端应用程序时反复遇到此错误。 有人可以帮助解决这个问题吗? 最佳答案 我想知道您的客户端应用程序向 Vertica 发送了哪种“查询”(以 RE
我有一个创建锁的方法。 ReadWriteLock lock = new ReentrantReadWriteLock(); 然后我使用 Lock Interface 将该对象传递到一个方法中。 m
正如问题所问,我知道这是可能的on Linux ,但我找不到任何适用于 Windows 的最新信息。有可能吗? 最佳答案 您可以使用 ctypes 加载 user32.dll 然后调用 GetKeyS
这是同一个问题 Change keyboard locks in Python或者 How to change caps lock status without key press . 但还是有区别的
与 this question 相同,不知道为什么Java团队没有在Lock中添加一些默认方法界面,类似这样: public default void withLock(Runnable r) {
我有一个带有package-lock.json文件的项目。 现在,我想基于yarn.lock文件或项目的现有package-lock.json生成node_modules文件。 我怎样才能做到这一点?
我正在查看 pthreadtypes.h 文件中的 pthread_mutex_t 结构。 “__lock”代表什么?它就像分配给互斥锁的锁号吗? typedef union { struct _
我正在研究避免死锁的措施,其中一种可能的方法是通过强制线程放弃它在访问另一个锁但无法访问该锁时已经持有的锁来打破循环等待。 以最简单的银行账户转账为例: class Account { priva
我被要求支持一些遗留代码,我看到了一些让我摸不着头脑的事情。在某些代码段中,我看到类实例使用 CMutex 实例来同步方法执行。例如 class CClassA : public CObject {
当我们调用 lock.lock() 或尝试进入一个 synchronized block 时,如果其他线程已经获取了该锁,我们的线程就会阻塞。现在我的问题是,当我们查看 lock.lock() 的实现
我是一名优秀的程序员,十分优秀!