TERASOLUNA Framework

非同期バッチデーモンのコレクタは、
ステータス変更後にキューイングに成功した時点でコミットを発行する手順
(ジョブ依頼情報取得⇒キューイング⇒コミットとなっており、
コレクタはキューイングできるまで処理を待ちます)
となっています。
コレクタ内の処理ではロックをかけていません。
そのため、DBが行ロックに対応していない場合は下記の事象が発生すると思われます。

使用しているDBは何でしょうか？

(1)について
そのとおりです。

(2)について
競合発生のフローについてはご認識の通りで正しいです。
また、ご提示いただいた対応1、2のどちらでも対応できると
考えておりますが対応案1の方が良いかと考えます。

対応案2についてですが、
キューの長さは理論的にはInteger.MAX_VALUE()まで設定できますが、
現実的には一度に登録するジョブの個数より少し大きい値を設定していただければ
と思います。(今回のケースでは60で良いと思います)
ただし、対応案2を採用するに当たっては考慮しておく点があり、
STOPレコードにより非同期バッチデーモンを停止するには
すでにキューにputされているジョブをすべて実行する必要があるので、
急遽デーモンを停止するような場合にすぐ停止できなくなります。

お世話になっております。

他の記事を参考にし、キューサイズを変更してみることにしました。
次の設定が関連すると思われます。

/batchapps/template/NoTransactionBean.xml
<!-- ===================== マネージャ定義 ===================== -->
<!-- 一段目のマネージャ -->
<bean id="jobManager" parent="baseManager">
<property name="name" value="noTransactionJobManager" />
<property name="collector" ref="collector" />
<property name="workQueueFactory">
<bean class="${workQueueFactory.class}">
<property name="workerExecutorService" ref="workerExecutorService" />
<property name="queueLength" ref="chunkQueueLength" />■

■/batchapps/common/DefaultValueBean.xml
<!-- チャンクキューサイズ -->
<bean id="chunkQueueLength" class="java.lang.Integer">
<!-- 10 → 100 -->
<constructor-arg value="100" />●
</bean>

以下は、queueLength をキーにして検索しましたが、同様に変更する必要のあるものか
教えてもらえませんでしょうか？

/batchapps/common/AsyncBatchDaemonForCommonjBean.xml

<!-- 非同期バッチ起動用のマネージャ -->
<bean id="jobManager" parent="baseManager">
<property name="name" value="AsyncBatchDaemonManager" />
<property name="collector" ref="batchDaemonJobCollector" />
<property name="workQueueFactory">
<bean class="${workQueueFactory.class}">
<property name="workerExecutorService" ref="workerExecutorService" />
<property name="queueProcessor" ref="asyncBatchDaemonQueueProcessor" />
<property name="queueLength" value="10" />●

/batchapps/common/AsyncBatchDaemonBean.xml

<!-- ===================== マネージャ定義 ===================== -->
<!-- 非同期バッチ起動用のマネージャ -->
<bean id="jobManager" parent="baseManager">
<property name="name" value="AsyncBatchDaemonManager" />
<property name="collector" ref="batchDaemonJobCollector" />
<property name="workQueueFactory">
<bean class="jp.terasoluna.fw.batch.standard.StandardWorkQueueFactory">
<property name="workerExecutorService" ref="workerExecutorService" />
<property name="queueProcessor" ref="asyncBatchDaemonQueueProcessor" />
<property name="queueLength" value="10" />●