你可以创建这个方法 getTask 作为同步方法：
如：

synchronized Task getTask() {
  // get NEW task from DB
  // update status to PROCESSING
  // return task
}

编辑1：如果是，只需使用SELECTFORUPDATE查询来阻止其他查询访问同一任务。如：

SELECT * FROM Task t WHERE t.status = NEW ORDER BY t.created_ts LIMIT 1 FOR UPDATE;
UPDATE Task SET status = PROCESSING WHERE id = <the task id> .

您可以创建一个过程来 Package 查询。

你可以这样处理原子性或事务问题，
使用任务的id，假设它是增量的。如果有三台机器运行任务调度。然后只需将id修改为3，并将结果为0、1、2的任务分配给固定的机器。所以不同的机器不会互相干扰（或竞争状况）