Author: manik.surtani(a)jboss.com Date: 2008-11-13 13:39:16 -0500 (Thu, 13 Nov 2008) New Revision: 7136 Modified: core/trunk/src/main/docbook/userguide/en/modules/configuration_reference.xml core/trunk/src/main/java/org/jboss/cache/config/Configuration.java Log: Changed default queue sizes Modified: core/trunk/src/main/docbook/userguide/en/modules/configuration_reference.xml =================================================================== --- core/trunk/src/main/docbook/userguide/en/modules/configuration_reference.xml 2008-11-13 18:37:16 UTC (rev 7135) +++ core/trunk/src/main/docbook/userguide/en/modules/configuration_reference.xml 2008-11-13 18:39:16 UTC (rev 7136) @@ -57,7 +57,7 @@ --> <listeners asyncPoolSize="1" - asyncQueueSize="1000000"/> + asyncQueueSize="100000"/> <!-- Used to enable invocation batching and allow the use of Cache.startBatch()/endBatch() methods. @@ -993,8 +993,8 @@ <row> <entry><emphasis role="bold">asyncQueueSize</emphasis></entry> <entry>listenerAsyncQueueSize</entry> - <entry>integer</entry> - <entry>1000000</entry> + <entry>positive integer</entry> + <entry>50000</entry> <entry> The size of the bounded queue used by the async listener threadpool. Only considered if @@ -2781,7 +2781,7 @@ <entry><emphasis role="bold">serializationExecutorQueueSize</emphasis></entry> <entry>serializationExecutorQueueSize</entry> <entry>positive integer</entry> - <entry>1000000</entry> + <entry>50000</entry> <entry> This is used to define the size of the bounded queue that holds tasks for the serialization executor. This is ignored if a serialization executor is not used, such as when <literal>serializationExecutorPoolSize</literal> Modified: core/trunk/src/main/java/org/jboss/cache/config/Configuration.java =================================================================== --- core/trunk/src/main/java/org/jboss/cache/config/Configuration.java 2008-11-13 18:37:16 UTC (rev 7135) +++ core/trunk/src/main/java/org/jboss/cache/config/Configuration.java 2008-11-13 18:39:16 UTC (rev 7136) @@ -224,9 +224,9 @@ private boolean writeSkewCheck = false; private int concurrencyLevel = 500; private int listenerAsyncPoolSize = 1; - private int listenerAsyncQueueSize = 1000000; + private int listenerAsyncQueueSize = 50000; private int serializationExecutorPoolSize = 0; - private int serializationExecutorQueueSize = 1000000; + private int serializationExecutorQueueSize = 50000; @Start(priority = 1) void correctIsolationLevels() @@ -462,7 +462,7 @@ } /** - * Sets the queue size of the bounded queue used to store async listener events on. This defaults to 1,000,000. + * Sets the queue size of the bounded queue used to store async listener events on. This defaults to 50,000. * * @param listenerAsyncQueueSize queue size to use */ @@ -473,7 +473,7 @@ } /** - * Sets the queue size of the bounded queue used to store async serialization events on. This defaults to 1,000,000. + * Sets the queue size of the bounded queue used to store async serialization events on. This defaults to 50,000. * * @param serializationExecutorQueueSize queue size to use */