int deltaRange = 10000;
    String key = "key";

    AtomicLongMap<String> map = AtomicLongMap.create();

    ExecutorService threadPool = newFixedThreadPool(nThreads);
    ArrayList<Future<Long>> futures = new ArrayList<>();
    for (int i = 0; i < nTasks; i++) {
      futures.add(
          threadPool.submit(
              new Callable<Long>() {
                @Override
                public Long call() {

        final String[] result = (String[]) SerializeUtil.fromBinaryToObject(binary);
        assertEquals(arr.length, result.length);
        assertEquals(arr[0], result[0]);

        // Test ArrayList
        final List<String> list = new ArrayList<>();
        list.add("item1");
        list.add("item2");
        binary = SerializeUtil.fromObjectToBinary(list);
        @SuppressWarnings("unchecked")

            java.util.regex.Pattern.CASE_INSENSITIVE
        );

    private void gatherBadSnippetsInFile(File file, Map<File, List<Error>> errors) {
        List<String> lines = new ArrayList<>();
        try (java.util.stream.Stream<String> stream = Files.lines(file.toPath())) {
            stream.forEach(lines::add);
        } catch (IOException ex) {
            // If a file can't be read, add an error

            System.exit(2);
        }

        Map<String, String> props = readProperties(propsPath);

        List<String> missing = new ArrayList<>();
        List<String> empty = new ArrayList<>();

        for (String rawKey : args) {
            String key = rawKey.trim();
            if (key.isEmpty()) continue;
            if (!props.containsKey(key)) {

 * either express or implied. See the License for the specific language
 * governing permissions and limitations under the License.
 */
package org.codelibs.fess.opensearch.config.exentity;

import java.util.ArrayList;
import java.util.Arrays;
import java.util.Collections;
import java.util.List;

import org.codelibs.core.lang.StringUtil;
import org.codelibs.fess.mylasta.direction.FessConfig;

    SerializableTester.reserializeAndAssert(map.entrySet());
    SerializableTester.reserializeAndAssert(map.keySet());
    assertEquals(
        new ArrayList<>(map.values()),
        new ArrayList<>(SerializableTester.reserialize(map.values())));
  }

    SerializableTester.reserializeAndAssert(map.entrySet());
    SerializableTester.reserializeAndAssert(map.keySet());
    assertEquals(
        new ArrayList<>(map.values()),
        new ArrayList<>(SerializableTester.reserialize(map.values())));
  }

 */

package org.elasticsearch.gradle.internal.vagrant;

import org.gradle.api.DefaultTask;
import org.gradle.api.tasks.Input;
import org.gradle.api.tasks.TaskAction;

import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;
import java.util.function.UnaryOperator;
import java.util.stream.Collectors;

import static org.elasticsearch.gradle.internal.vagrant.VagrantMachine.convertLinuxPath;

                }
            }
        }

        if (parentImports != null) {
            parentImports = new ArrayList<>(parentImports);
        } else {
            parentImports = new ArrayList<>();
        }

        if (foreignImports != null) {
            foreignImports = new TreeMap<>(foreignImports);
        } else {

 * either express or implied. See the License for the specific language
 * governing permissions and limitations under the License.
 */
package org.codelibs.fess.helper;

import java.util.ArrayList;
import java.util.List;

import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import org.codelibs.fess.app.service.DuplicateHostService;