From a89f7014aeb71dba5c94404dfea7eb89e7eeee74 Mon Sep 17 00:00:00 2001
From: Jean-Noel Rouvignac <jean-noel.rouvignac@forgerock.com>
Date: Wed, 08 Jul 2015 06:48:02 +0000
Subject: [PATCH] AutoRefactor'ed Use Diamond Operator
---
opendj-server-legacy/src/main/java/org/opends/server/extensions/ParallelWorkQueue.java | 9 ++++-----
1 files changed, 4 insertions(+), 5 deletions(-)
diff --git a/opendj-server-legacy/src/main/java/org/opends/server/extensions/ParallelWorkQueue.java b/opendj-server-legacy/src/main/java/org/opends/server/extensions/ParallelWorkQueue.java
index 200c5a9..67d600a 100644
--- a/opendj-server-legacy/src/main/java/org/opends/server/extensions/ParallelWorkQueue.java
+++ b/opendj-server-legacy/src/main/java/org/opends/server/extensions/ParallelWorkQueue.java
@@ -137,11 +137,10 @@
computeNumWorkerThreads(configuration.getNumWorkerThreads());
// Create the actual work queue.
- opQueue = new ConcurrentLinkedQueue<Operation>();
+ opQueue = new ConcurrentLinkedQueue<>();
- // Create the set of worker threads that should be used to service the
- // work queue.
- workerThreads = new ArrayList<ParallelWorkerThread>(numWorkerThreads);
+ // Create the set of worker threads that should be used to service the work queue.
+ workerThreads = new ArrayList<>(numWorkerThreads);
for (lastThreadNumber = 0; lastThreadNumber < numWorkerThreads;
lastThreadNumber++)
{
@@ -179,7 +178,7 @@
// Send responses to any operations in the pending queue to indicate that
// they won't be processed because the server is shutting down.
CancelRequest cancelRequest = new CancelRequest(true, reason);
- ArrayList<Operation> pendingOperations = new ArrayList<Operation>();
+ ArrayList<Operation> pendingOperations = new ArrayList<>();
opQueue.removeAll(pendingOperations);
for (Operation o : pendingOperations)
--
Gitblit v1.10.0