Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 16 for Runnable (0.04 sec)

  1. okhttp/src/androidMain/baseline-prof.txt

    HSPLokhttp3/internal/concurrent/TaskRunner$RealBackend;->execute(Lokhttp3/internal/concurrent/TaskRunner;Ljava/lang/Runnable;)V
    HSPLokhttp3/internal/concurrent/TaskRunner$RealBackend;->nanoTime()J
    HSPLokhttp3/internal/concurrent/TaskRunner$runnable$1;-><init>(Lokhttp3/internal/concurrent/TaskRunner;)V
    HSPLokhttp3/internal/concurrent/TaskRunner$runnable$1;->run()V
    HSPLokhttp3/internal/concurrent/TaskRunner;-><clinit>()V
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Mon Dec 30 23:28:56 UTC 2024
    - 127.9K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/util/concurrent/ClosingFuture.java

            return whenClosed = new CountDownLatch(1);
          }
        }
      }
    
      /**
       * Returns an object that can be used to wait until this objects' deferred closeables have all had
       * {@link Runnable}s that close them submitted to each one's closing {@link Executor}.
       */
      @VisibleForTesting
      CountDownLatch whenClosedCountDown() {
        return closeables.whenClosedCountDown();
      }
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 23 15:26:56 UTC 2025
    - 97.8K bytes
    - Viewed (0)
  3. guava/src/com/google/common/util/concurrent/ClosingFuture.java

            return whenClosed = new CountDownLatch(1);
          }
        }
      }
    
      /**
       * Returns an object that can be used to wait until this objects' deferred closeables have all had
       * {@link Runnable}s that close them submitted to each one's closing {@link Executor}.
       */
      @VisibleForTesting
      CountDownLatch whenClosedCountDown() {
        return closeables.whenClosedCountDown();
      }
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Wed Jul 23 15:26:56 UTC 2025
    - 98.1K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/opensearch/client/SearchEngineClient.java

        /**
         * Flushes configuration files to the search engine and executes a callback.
         *
         * @param callback the callback to execute after flushing
         */
        public void flushConfigFiles(final Runnable callback) {
            final FessConfig fessConfig = ComponentUtil.getFessConfig();
    
            final String fesenType = fessConfig.getFesenType();
            switch (fesenType) {
            case Constants.FESEN_TYPE_CLOUD:
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sun Aug 31 08:19:00 UTC 2025
    - 121.9K bytes
    - Viewed (0)
  5. src/main/webapp/css/admin/bootstrap.min.css

    appearance:none;appearance:none}@media (prefers-reduced-motion:reduce){.custom-range::-webkit-slider-thumb{-webkit-transition:none;transition:none}}.custom-range::-webkit-slider-thumb:active{background-color:#b3d7ff}.custom-range::-webkit-slider-runnable-track{width:100%;height:.5rem;color:transparent;cursor:pointer;background-color:#dee2e6;border-color:transparent;border-radius:1rem}.custom-range::-moz-range-thumb{width:1rem;height:1rem;background-color:#007bff;border:0;border-radius:1rem;-moz-...
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sat Oct 26 01:49:09 UTC 2024
    - 158.5K bytes
    - Viewed (0)
  6. cmd/sts-handlers_test.go

    	err = s.adm.SetUser(ctx, accessKey, secretKey, madmin.AccountEnabled)
    	if err != nil {
    		c.Fatalf("Unable to set user: %v", err)
    	}
    
    	_, err = s.adm.AttachPolicy(ctx, madmin.PolicyAssociationReq{
    		Policies: []string{policy},
    		User:     accessKey,
    	})
    	if err != nil {
    		c.Fatalf("Unable to attach policy: %v", err)
    	}
    
    	// confirm that the user is able to access the bucket
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 100.2K bytes
    - Viewed (1)
  7. cmd/site-replication.go

    		if err != nil {
    			return psi, errSRPeerResp(fmt.Errorf("unable to create admin client for %s: %w", v.Name, err))
    		}
    
    		info, err := admClient.ServerInfo(ctx)
    		if err != nil {
    			return psi, errSRPeerResp(fmt.Errorf("unable to fetch server info for %s: %w", v.Name, err))
    		}
    
    		s3Client, err := getS3Client(v)
    		if err != nil {
    			return psi, errSRPeerResp(fmt.Errorf("unable to create s3 client for %s: %w", v.Name, err))
    		}
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 184.7K bytes
    - Viewed (0)
  8. cmd/bucket-replication.go

    		maxWorkers := p.maxWorkers
    		p.mu.RUnlock()
    		switch prio {
    		case "fast":
    			replLogOnceIf(GlobalContext, fmt.Errorf("Unable to keep up with incoming traffic"), string(replicationSubsystem), logger.WarningKind)
    		case "slow":
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 118K bytes
    - Viewed (0)
  9. src/main/webapp/css/bootstrap.min.css

    ease-in-out;-webkit-appearance:none;appearance:none}@media (prefers-reduced-motion:reduce){.form-range::-webkit-slider-thumb{-webkit-transition:none;transition:none}}.form-range::-webkit-slider-thumb:active{background-color:#b6d4fe}.form-range::-webkit-slider-runnable-track{width:100%;height:.5rem;color:transparent;cursor:pointer;background-color:var(--bs-tertiary-bg);border-color:transparent;border-radius:1rem}.form-range::-moz-range-thumb{width:1rem;height:1rem;background-color:#0d6efd;border:0;border-radiu...
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sun Jan 12 06:14:02 UTC 2025
    - 227.5K bytes
    - Viewed (0)
  10. cmd/metrics-v2.go

    				),
    				prometheus.GaugeValue,
    				float64(v),
    				append(values, k)...)
    			if err != nil {
    				// Enable for debugging
    				if serverDebugLog {
    					bugLogIf(GlobalContext, fmt.Errorf("unable to validate prometheus metric (%w) %v+%v", err, values, metric.Histogram))
    				}
    			} else {
    				out <- pmetric
    			}
    		}
    		return
    	}
    	metricType := prometheus.GaugeValue
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 133.4K bytes
    - Viewed (0)
Back to top