Function/service/queue/QueueHandlerContainerService - Nimbus Wiki - Nimbus

QueueHandlerContainer実装サービス jp.ossc.nimbus.service.queue.QueueHandlerContainerService

jp.ossc.nimbus.service.queue.QueueHandlerContainerServiceは、非同期処理を実現するQueueHandlerContainer実装サービスです。
Queueの後ろで処理をするスレッドは、複数にする事ができますが、その場合、並列に処理されるため、処理の順序性は保証できなくなります。
処理順序を保ちつつ、並列で処理したい場合は、DistributedQueueHandlerContainerServiceを参照して下さい。

このサービスは、複合的なサービスで、以下のサービスを下位サービスとして使用します。

下位サービスインタフェース	用途
jp.ossc.nimbus.service.queue.Queue	非同期処理要求を受け付ける内部キュー。
jp.ossc.nimbus.service.queue.QueueHandler	非同期処理を行うサービス。

以下に簡単なサービス定義を示します。

 <?xml version="1.0" encoding="Shift_JIS"?>
 <!DOCTYPE server PUBLIC
   "-//Nimbus//DTD Nimbus 1.0//JA"
   "http://nimbus.sourceforge.jp/dtd/nimbus-service_1_0.dtd">
 
 <server>
     
     <manager>
         
         <!-- 非同期処理を行うQueueHandlerサービスのコンテナとなるQueueHandlerContainerサービス -->
         <service name="QueueHandlerContainer"
                  code="jp.ossc.nimbus.service.queue.QueueHandlerContainerService">
             
             <!-- 非同期処理を行うスレッド数を設定する -->
             <attribute name="QueueHandlerSize">5</attribute>
             
             <!-- 非同期処理を行うQueueHandlerサービスのサービス名を設定する -->
             <attribute name="QueueHandlerServiceName">#QueueHandler</attribute>
             
             <depends>QueueHandler</depends>
             
         </service>
         
         <!-- 非同期処理を行うQueueHandlerサービス -->
         <service name="QueueHandler"
                  code="SampleQueueHandlerService"/>
         
         <!-- 非同期処理の応答を返すためのQueueサービス -->
         <service name="ResponseQueue"
                  code="jp.ossc.nimbus.service.queue.DefaultQueueService"
                  instance="factory">
         
     </manager>
     
 </server>

---

キュー/QueueHandlerContainer