读取数据库表的行上的锁

Question

我正在尝试建立一个作业调度程序。我有一个作业列表，可以在2-3台不同的机器上按时间执行。因此，任何机器都可以挑选任何作业并执行它，只要它的next_execution_time < current_time。我将所有作业存储在一个数据库表中，并使用SELECT.... FOR UPDATE中的SQL来选择要执行的作业。

但这种方法的问题是，如果一个machine1选择了一个作业，因为只有写锁，其他机器也会选择执行相同的作业，但不能执行，因为它们将等待锁释放或发生锁超时。那么有没有办法让其他机器跳过这个作业，使用SQL锁来执行其他作业呢？是否不应在数据库中添加其他列？

Flow是这样的：

select a job and lock it -> execute the job -> release the lock

我正在使用ruby-on-rails来开发它。如果rails中没有-wait或set_lock_timeout =0。它可能会解决这个问题。如果真的存在。语法是什么？

Answer 1

实际上，在mysql中，您有一个简单的方法来处理当前表，您需要在选择下一个任务时临时锁定表。我假设您在表中有一个列来标记已经开始/完成的任务，否则您可以使用与datetime相同的列来启动作业，以标记它已经完成/开始：

lock tables jobs write;

select * from jobs where start_time < current_time and status = 'pending' order by start_time;
-- be carefull here to check for SQL errors in your code and run unlock tables if an exception is thrown or something like that

update jobs set status = 'started' where id = the_one_you_selected_adobe;

unlock tables;

就是这样，多个并发线程/进程可以使用作业表来执行任务，而无需两个线程运行相同的任务。