Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 901 - 910 of 1,497 for remove (0.11 seconds)

The search processing time has exceeded the limit. The displayed results may be partial.

  1. android/guava/src/com/google/common/base/internal/Finalizer.java

      @SuppressWarnings("InfiniteLoopStatement")
      @Override
      public void run() {
        while (true) {
          try {
            if (!cleanUp(queue.remove())) {
              break;
            }
          } catch (InterruptedException e) {
            // ignore
          }
        }
      }
    
      /**
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Mar 11 03:19:29 GMT 2026
    - 9.6K bytes
    - Click Count (0)
  2. android/guava/src/com/google/common/util/concurrent/ListenableFuture.java

     * inFlight.add(name);
     * ListenableFuture<Result> future = service.query(name);
     * future.addListener(new Runnable() {
     *   public void run() {
     *     processedCount.incrementAndGet();
     *     inFlight.remove(name);
     *     lastProcessed.set(name);
     *     logger.info("Done with {0}", name);
     *   }
     * }, executor);
     * }
     *
     * <h3>How to get an instance</h3>
     *
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Jan 29 22:14:05 GMT 2026
    - 8K bytes
    - Click Count (0)
  3. src/main/java/org/codelibs/fess/ldap/LdapManager.java

                            stream(user.getGroupNames()).of(stream -> stream.forEach(name -> {
                                if (oldGroupList.contains(name)) {
                                    oldGroupList.remove(name);
                                    newGroupList.remove(name);
                                }
                            }));
                            oldGroupList.stream().forEach(name -> {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Jan 02 08:06:20 GMT 2026
    - 85.2K bytes
    - Click Count (0)
  4. guava/src/com/google/common/base/internal/Finalizer.java

      @SuppressWarnings("InfiniteLoopStatement")
      @Override
      public void run() {
        while (true) {
          try {
            if (!cleanUp(queue.remove())) {
              break;
            }
          } catch (InterruptedException e) {
            // ignore
          }
        }
      }
    
      /**
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Mar 11 03:19:29 GMT 2026
    - 9.6K bytes
    - Click Count (0)
  5. cmd/erasure-heal_test.go

    			staleDisks[j] = badDisk{nil}
    		}
    
    		staleWriters := make([]io.Writer, len(staleDisks))
    		for i, disk := range staleDisks {
    			if disk == nil {
    				continue
    			}
    			os.Remove(pathJoin(disk.String(), "testbucket", "testobject"))
    			staleWriters[i] = newBitrotWriter(disk, "", "testbucket", "testobject", erasure.ShardFileSize(test.size), test.algorithm, erasure.ShardSize())
    		}
    
    Created: Sun Apr 05 19:28:12 GMT 2026
    - Last Modified: Fri Aug 29 02:39:48 GMT 2025
    - 7.9K bytes
    - Click Count (0)
  6. src/main/java/org/codelibs/fess/indexer/IndexUpdater.java

                                logger.debug("Skipped indexing (not a target): url={}", accessResult.getUrl());
                            }
                            continue;
                        }
                        map.remove(Constants.INDEXING_TARGET);
    
                        updateDocument(map);
    
                        docList.add(ingest(accessResult, map));
                        final long contentSize = indexingHelper.calculateDocumentSize(map);
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Nov 28 16:29:12 GMT 2025
    - 32.9K bytes
    - Click Count (0)
  7. api/maven-api-core/src/main/java/org/apache/maven/api/services/ProblemCollector.java

                        List<P> problems = getProblems(s);
                        while (!problems.isEmpty()) {
                            try {
                                return problems.remove(0) != null;
                            } catch (IndexOutOfBoundsException e) {
                                // empty, continue
                            }
                        }
                    }
                }
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Fri Jul 18 17:30:19 GMT 2025
    - 11.4K bytes
    - Click Count (0)
  8. compat/maven-compat/src/main/java/org/apache/maven/project/artifact/DefaultMavenMetadataCache.java

                }
                return new ResolutionGroup(
                        pomArtifact, relocatedArtifact, artifacts, managedVersions, cacheRecord.getRemoteRepositories());
            }
    
            cache.remove(cacheKey);
    
            return null;
        }
    
        @Override
        public void put(
                Artifact artifact,
                boolean resolveManagedVersions,
                ArtifactRepository localRepository,
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Fri Jun 06 14:28:57 GMT 2025
    - 11.8K bytes
    - Click Count (0)
  9. android/guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java

          tasks.add(command);
        }
    
        boolean hasNext() {
          return !tasks.isEmpty();
        }
    
        void runNext() {
          assertTrue("expected at least one task to run", hasNext());
          tasks.remove().run();
        }
    
        void runAll() {
          while (hasNext()) {
            runNext();
          }
        }
      }
    
      private FakeExecutor fakePool;
      private SequentialExecutor e;
    
      @Override
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 10.5K bytes
    - Click Count (0)
  10. futures/listenablefuture1/src/com/google/common/util/concurrent/ListenableFuture.java

     * inFlight.add(name);
     * ListenableFuture<Result> future = service.query(name);
     * future.addListener(new Runnable() {
     *   public void run() {
     *     processedCount.incrementAndGet();
     *     inFlight.remove(name);
     *     lastProcessed.set(name);
     *     logger.info("Done with {0}", name);
     *   }
     * }, executor);
     * }
     *
     * <h3>How to get an instance</h3>
     *
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Jan 29 22:14:05 GMT 2026
    - 8K bytes
    - Click Count (0)
Back to Top