1

私は Weblogic 10.3、Spring 2.0、Oracle 11g を使用しています。「threadpoolexecutor」将来のタスク (async resp) を使用しようとすると、スレッド プール エグゼキューターによって実行される Bean が「prototype」であるため、非同期応答の待機中に次の例外が発生します。

注:Spring の ClassPathXmlApplicationContext を使用して Bean を取得している場合、例外が発生しません。これは、すべての Bean を再度ロードするため、Bean を取得するための推奨される方法ではありません。

springContextAware 、ApplicationObjectSupport; を試しました。それらも私にとってはうまくいきませんでした。

 - Error:

]", which is more than the configured time (StuckThreadMaxTime) of "600" seconds. Stack trace:
        sun.misc.Unsafe.park(Native Method)
        java.util.concurrent.locks.LockSupport.park(LockSupport.java:158)
        java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(AbstractQueuedSynchronizer.java:811)
        java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireSharedInterruptibly(AbstractQueuedSynchronizer.java:969)
        java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireSharedInterruptibly(AbstractQueuedSynchronizer.java:1281)
        java.util.concurrent.FutureTask$Sync.innerGet(FutureTask.java:218)

私が持っているBeanの定義は

    <bean id="PtTaskExecutor"
            class="java.util.concurrent.ThreadPoolExecutor">
            <constructor-arg index="0" value="1"/>  <!--  corePoolSize -->
            <constructor-arg index="1" value="3"/>  <!--  maximumPoolSize --> 
            <constructor-arg index="2" type="long" value="180"/><!-- 3 minutes -->
<!-- keepAliveTime --> 
            <constructor-arg index="3" type="java.util.concurrent.TimeUnit">    
<!-- the time unit for the keepAliveTime argument -->
            <util:constant static-field="java.util.concurrent.TimeUnit.SECONDS"/>
            </constructor-arg>
            <constructor-arg index="4" type="java.util.concurrent.BlockingQueue"> 
 <!-- the queue for holding tasks before they are executed -->
                <bean name="LinkedBlockingQueue" class="java.util.concurrent.LinkedBlockingQueue">
                    <constructor-arg index="0" type="int" value="3"/> <!-- capacity -->
                </bean>
            </constructor-arg>

            <constructor-arg index="5" type="java.util.concurrent.RejectedExecutionHandler">
 <!--Execute with caller threads if queue is full -->
                    <bean class="java.util.concurrent.ThreadPoolExecutor$CallerRunsPolicy"/>
            </constructor-arg>
            </bean>

    <bean id="xTask" class="***.****.*.*.*.*.XTask" scope="prototype">
            <property name="XDao" ref="XDao" />
            <property name="transactionTemplate" ref="transactionTemplate"/>
        </bean>  




-----The code part 

    Future<YResponseBean[]> responseArr = pTaskExecutor
                        .submit(xTask);

                responseMap.put(i, responseArr);

then the error is from here

    for (Integer i : keySet) {
                    // Waits for the thread response
                    responses[i] = responseMap.get(i).get()[0];
                }

私も試してみましlazy-init=trueたがthreadpoolexecutor、運が悪いです。

4

1 に答える 1