minor change

Author: clausnagel

citydb-io-citygml/src/main/java/org/citydb/io/citygml/writer/CityGMLWriter.java

@@ -77,9 +77,7 @@ public CityGMLWriter(OutputFile file, WriteOptions options, CityGMLAdapterContex
             throw new WriteException("Failed to initialize local cache.", e);
         }
 
-        service = ExecutorHelper.newFixedAndBlockingThreadPool(1, (options.getNumberOfThreads() > 0 ?
-                options.getNumberOfThreads() :
-                Math.max(2, Runtime.getRuntime().availableProcessors())) * 2);
+        service = ExecutorHelper.newFixedAndBlockingThreadPool(1, 100);
         helpers = ThreadLocal.withInitial(() -> new ModelSerializerHelper(this, store, context)
                 .initialize(options, formatOptions));
         countLatch = new CountLatch();

citydb-io-citygml/src/main/java/org/citydb/io/citygml/writer/CityJSONWriter.java

@@ -84,9 +84,7 @@ public CityJSONWriter(OutputFile file, WriteOptions options, CityGMLAdapterConte
             throw new WriteException("Failed to initialize local cache.", e);
         }
 
-        service = ExecutorHelper.newFixedAndBlockingThreadPool(1, (options.getNumberOfThreads() > 0 ?
-                options.getNumberOfThreads() :
-                Math.max(2, Runtime.getRuntime().availableProcessors())) * 2);
+        service = ExecutorHelper.newFixedAndBlockingThreadPool(1, 100);
         helpers = ThreadLocal.withInitial(() -> new ModelSerializerHelper(this, store, adapterContext)
                 .initialize(options, formatOptions));
         countLatch = new CountLatch();

citydb-operation/src/main/java/org/citydb/operation/exporter/Exporter.java

@@ -76,7 +76,8 @@ public Exporter startSession(DatabaseAdapter adapter, ExportOptions options) thr
             helpers = ConcurrentHashMap.newKeySet();
             service = ExecutorHelper.newFixedAndBlockingThreadPool(options.getNumberOfThreads() > 0 ?
                     options.getNumberOfThreads() :
-                    Math.max(2, Runtime.getRuntime().availableProcessors()));
+                    Math.max(2, Runtime.getRuntime().availableProcessors()),
+                    1000);
 
             countLatch = new CountLatch();
             contexts = ThreadLocal.withInitial(() -> {