Search Options

Results per page
Sort
Preferred Languages
Advance

Results 31 - 40 of 371 for polo (0.02 sec)

  1. guava-tests/test/com/google/common/collect/InternersTest.java

        String not = new String("a");
    
        Interner<String> pool = Interners.newStrongInterner();
        assertSame(canonical, pool.intern(canonical));
        assertSame(canonical, pool.intern(not));
      }
    
      public void testStrong_null() {
        Interner<String> pool = Interners.newStrongInterner();
        assertThrows(NullPointerException.class, () -> pool.intern(null));
      }
    
      public void testStrong_builder() {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Dec 19 18:03:30 UTC 2024
    - 4K bytes
    - Viewed (0)
  2. guava-testlib/src/com/google/common/collect/testing/testers/QueuePollTester.java

      public void testPoll_empty() {
        assertNull("emptyQueue.poll() should return null", getQueue().poll());
        expectUnchanged();
      }
    
      @CollectionFeature.Require(SUPPORTS_REMOVE)
      @CollectionSize.Require(ONE)
      public void testPoll_size1() {
        assertEquals("size1Queue.poll() should return first element", e0(), getQueue().poll());
        expectMissing(e0());
      }
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Nov 14 23:40:07 UTC 2024
    - 2.5K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/fess/ds/callback/FileListIndexUpdateCallbackImpl.java

        /**
         * Creates a new fixed thread pool executor with the specified number of threads.
         *
         * @param nThreads the number of threads in the pool
         * @return a new ThreadPoolExecutor configured for this callback
         */
        protected ExecutorService newFixedThreadPool(final int nThreads) {
            if (logger.isDebugEnabled()) {
                logger.debug("Executor Thread Pool: {}", nThreads);
            }
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Aug 07 03:06:29 UTC 2025
    - 28.9K bytes
    - Viewed (0)
  4. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchUrlQueueService.java

         */
        @Override
        public OpenSearchUrlQueue poll(final String sessionId) {
            final QueueHolder queueHolder = getQueueHolder(sessionId);
            final Queue<OpenSearchUrlQueue> waitingQueue = queueHolder.waitingQueue;
            final Queue<OpenSearchUrlQueue> crawlingQueue = queueHolder.crawlingQueue;
            OpenSearchUrlQueue urlQueue = waitingQueue.poll();
            if (urlQueue != null) {
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Thu Aug 07 02:55:08 UTC 2025
    - 17K bytes
    - Viewed (0)
  5. cmd/erasure-server-pool-decom_gen_test.go

    Harshavardhana <******@****.***> 1641955723 -0800
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Wed Jan 12 02:48:43 UTC 2022
    - 11K bytes
    - Viewed (0)
  6. cmd/erasure-server-pool-rebalance_gen.go

    Krishnan Parthasarathi <******@****.***> 1711041695 -0700
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Mar 21 17:21:35 UTC 2024
    - 26.8K bytes
    - Viewed (0)
  7. cmd/fmt-gen.go

    	if err != nil {
    		log.Fatalf("failed to create format.json.zip: %v", err)
    	}
    	defer zipFile.Close()
    	fmtZipW := zip.NewWriter(zipFile)
    	defer fmtZipW.Close()
    	for _, pool := range pools { // for each pool
    		setCount, setDriveCount := pool.SetCount, pool.DrivesPerSet
    		format := newFormatErasureV3(setCount, setDriveCount)
    		format.ID = deploymentID
    		for i := range setCount { // for each erasure set
    			for j := range setDriveCount {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 3.7K bytes
    - Viewed (0)
  8. cmd/admin-handlers-pools.go

    			}
    		} else {
    			idx = globalEndpoints.GetPoolIdx(pool)
    			if idx == -1 {
    				// We didn't find any matching pools, invalid input
    				writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, errInvalidArgument), r.URL)
    				return
    			}
    		}
    		var pool *erasureSets
    		for pidx := range z.serverPools {
    			if pidx == idx {
    				pool = z.serverPools[idx]
    				break
    			}
    		}
    		if pool == nil {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Sep 04 20:47:24 UTC 2025
    - 11K bytes
    - Viewed (0)
  9. okhttp/src/jvmTest/kotlin/okhttp3/internal/connection/ConnectionPoolTest.kt

        // Running at time 75, the pool returns that nothing can be evicted until time 150.
        assertThat(pool.closeConnections(75L)).isEqualTo(75L)
        assertThat(pool.connectionCount()).isEqualTo(2)
    
        // Running at time 149, the pool returns that nothing can be evicted until time 150.
        assertThat(pool.closeConnections(149L)).isEqualTo(1L)
        assertThat(pool.connectionCount()).isEqualTo(2)
    
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 12.9K bytes
    - Viewed (0)
  10. docs/es/docs/tutorial/security/get-current-user.md

    ¿Quieres solo tener un `str`? ¿O solo un `dict`? ¿O un instance de clase modelo de base de datos directamente? Todo funciona de la misma manera.
    
    ¿En realidad no tienes usuarios que inicien sesión en tu aplicación sino robots, bots u otros sistemas, que solo tienen un token de acceso? Una vez más, todo funciona igual.
    
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Mon Dec 30 18:26:57 UTC 2024
    - 4.3K bytes
    - Viewed (0)
Back to top