assertArgumentNotNull("in", in);
        assertArgumentNotNull("out", out);

        final InputStream is = URLUtil.openStream(in);
        try {
            final FileOutputStream os = OutputStreamUtil.create(out);
            try {
                return copyInternal(wrap(is), os);
            } finally {
                CloseableUtil.close(os);
            }
        } finally {

   * found in any textbook.
   */

  /** Monitor guarding all access */
  final Monitor monitor;

  /** Guard for waiting takes */
  private final Monitor.Guard notEmpty;

  /** Guard for waiting puts */
  private final Monitor.Guard notFull;

  // Internal helper methods

  /** Circularly increment i. */
  final int inc(int i) {
    return (++i == items.length) ? 0 : i;
  }

  /**

        // Create multiple threads accessing the same property
        final String testKey = "domain.title";
        final int threadCount = 10;
        final Thread[] threads = new Thread[threadCount];
        final String[] results = new String[threadCount];

        for (int i = 0; i < threadCount; i++) {
            final int index = i;
            threads[i] = new Thread(() -> {

        try {
            System.setProperty(Constants.FESS_SEARCH_ENGINE_HTTP_ADDRESS, "thread-test");

            final String[] results = new String[10];
            Thread[] threads = new Thread[10];

            for (int i = 0; i < 10; i++) {
                final int index = i;
                threads[i] = new Thread(() -> {
                    results[index] = SystemUtil.getSearchEngineHttpAddress();

   * found in any textbook.
   */

  /** Monitor guarding all access */
  final Monitor monitor;

  /** Guard for waiting takes */
  private final Monitor.Guard notEmpty;

  /** Guard for waiting puts */
  private final Monitor.Guard notFull;

  // Internal helper methods

  /** Circularly increment i. */
  final int inc(int i) {
    return (++i == items.length) ? 0 : i;
  }

  /**

  // http://gee.cs.oswego.edu/cgi-bin/viewcvs.cgi/jsr166/src/main/java/util/concurrent/

  private static final long serialVersionUID = 5595510919245408276L;

  final PriorityQueue<E> q;
  final Monitor monitor = new Monitor(true);
  private final Monitor.Guard notEmpty =
      new Monitor.Guard(monitor) {
        @Override
        public boolean isSatisfied() {
          return !q.isEmpty();

    @Test
    public void test_mimetype_variable_replacement() {
        final String testCommand = "generate-thumbnail image ${url} ${outputFile} ${mimetype}";
        final String tempPath = "/tmp/test.gif";
        final String outputPath = "/tmp/thumbnail.png";
        final String mimeType = "image/gif";

        final String expandedCommand =

    public void test_multipleConcurrentSearches() throws Exception {
        final int numSearchThreads = 5;
        final CountDownLatch startLatch = new CountDownLatch(1);
        final CountDownLatch endLatch = new CountDownLatch(numSearchThreads);
        final List<List<Map<String, Object>>> allResults = new ArrayList<>();

        try (RankFusionProcessor processor = new RankFusionProcessor()) {

    private static final Logger log = LoggerFactory.getLogger(PersistentHandleManager.class);

    private final ConcurrentHashMap<String, HandleInfo> handles;
    private final ConcurrentHashMap<HandleGuid, HandleInfo> guidToHandle;
    private final Path stateDirectory;
    private final ScheduledExecutorService scheduler;
    private final CIFSContext context;

        } finally {
            cbWithTracking.close();
        }
    }

    @Test
    public void testRollingWindowMetrics() throws Exception {
        SmbCircuitBreaker cbWithWindow = new SmbCircuitBreaker("window-test");

        try {
            // Execute mixed operations
            for (int i = 0; i < 10; i++) {