Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 18 for waitms (0.06 sec)

  1. android/guava-tests/test/com/google/common/util/concurrent/AbstractClosingFutureTest.java

      final TestCloseable closeable2 = new TestCloseable("closeable2");
      final TestCloseable closeable3 = new TestCloseable("closeable3");
      final TestCloseable closeable4 = new TestCloseable("closeable4");
    
      final Waiter waiter = new Waiter();
      final CountDownLatch futureCancelled = new CountDownLatch(1);
      final Exception exception = new Exception();
      final Closeable mockCloseable = Mockito.mock(Closeable.class);
    
      @Override
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Fri Jul 11 18:52:30 UTC 2025
    - 75.4K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/cache/CacheBuilder.java

       * computes or retrieves it using the supplied {@code CacheLoader}. If another thread is currently
       * loading the value for this key, simply waits for that thread to finish and returns its loaded
       * value. Note that multiple threads can concurrently load values for distinct keys.
       *
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 51.7K bytes
    - Viewed (0)
  3. src/bufio/bufio_test.go

    // buffering writes to a network socket, excessive network writes should be
    // avoided.
    func TestWriterReadFromCounts(t *testing.T) {
    	var w0 writeCountingDiscard
    	b0 := NewWriterSize(&w0, 1234)
    	b0.WriteString(strings.Repeat("x", 1000))
    	if w0 != 0 {
    		t.Fatalf("write 1000 'x's: got %d writes, want 0", w0)
    	}
    	b0.WriteString(strings.Repeat("x", 200))
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Fri Feb 07 01:08:54 UTC 2025
    - 51.6K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/helper/ViewHelper.java

            if (client == null) {
                throw new FessSystemException("No CrawlerClient: " + configId + ", url: " + url);
            }
            return writeContent(configId, url, client);
        }
    
        /**
         * Writes content from a crawler client to a stream response.
         *
         * @param configId the configuration ID
         * @param url the document URL
         * @param client the crawler client
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 52.4K bytes
    - Viewed (0)
  5. okhttp/src/jvmTest/kotlin/okhttp3/internal/cache/DiskLruCacheTest.kt

        // We can't begin the edit if writing 'DIRTY' fails.
        filesystem.setFaultyWrite(journalFile, true)
        assertThat(cache.edit("c")).isNull()
    
        // Once the journal has a failure, subsequent writes aren't permitted.
        filesystem.setFaultyWrite(journalFile, false)
        assertThat(cache.edit("d")).isNull()
    
        // Confirm that the fault didn't corrupt entries stored before the fault was introduced.
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Wed Mar 19 19:25:20 UTC 2025
    - 75.7K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/api/json/SearchApiManager.java

            ComponentUtil.getFessConfig().getApiJsonResponseHeaderList().forEach(e -> response.setHeader(e.getFirst(), e.getSecond()));
        }
    
        /**
         * Writes a JSON response.
         * @param status The status code.
         * @param t The throwable.
         */
        protected void writeJsonResponse(final int status, final Throwable t) {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 54.6K bytes
    - Viewed (1)
  7. cmd/erasure-server-pool.go

    		g.Go(func() error {
    			// Get the set where it would be placed.
    			storageInfos[index] = getDiskInfos(ctx, pool.getHashedSet(object).getDisks()...)
    			return nil
    		}, index)
    	}
    
    	// Wait for the go routines.
    	g.Wait()
    
    	for i, zinfo := range storageInfos {
    		if zinfo == nil {
    			serverPools[i] = poolAvailableSpace{Index: i}
    			continue
    		}
    		var available uint64
    		if !isMinioMetaBucketName(bucket) {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 89.1K bytes
    - Viewed (0)
  8. android/guava/src/com/google/common/collect/MapMakerInternalMap.java

       * concurrently readable hash table. The map supports non-blocking reads and concurrent writes
       * across different segments.
       *
       * The page replacement algorithm's data structures are kept casually consistent with the map. The
       * ordering of writes to a segment is sequentially consistent. An update to the map and recording
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Aug 11 19:31:30 UTC 2025
    - 90K bytes
    - Viewed (0)
  9. android/guava/src/com/google/common/util/concurrent/Futures.java

      //    (hypothetical) unsafe read by our caller. Note: adding 'volatile' does not fix this issue,
      //    it would just add an edge such that if done() observed non-null, then it would also
      //    definitely observe all earlier writes, but we still have no guarantee that done() would see
      //    the initial write (just stronger guarantees if it does).
      //
      // See: http://cs.oswego.edu/pipermail/concurrency-interest/2015-January/013800.html
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 64.3K bytes
    - Viewed (0)
  10. cmd/xl-storage.go

    	if err != nil {
    		return err
    	}
    	defer metaDataPoolPut(wbuf)
    
    	return s.writeAllMeta(ctx, volume, pathJoin(path, xlStorageFormatFile), wbuf, !opts.NoPersistence)
    }
    
    // WriteMetadata - writes FileInfo metadata for path at `xl.meta`
    func (s *xlStorage) WriteMetadata(ctx context.Context, origvolume, volume, path string, fi FileInfo) (err error) {
    	if fi.Fresh {
    		if origvolume != "" {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Jun 13 11:33:47 UTC 2025
    - 91.7K bytes
    - Viewed (0)
Back to top