Search Options

Results per page
Sort
Preferred Languages
Advance

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

  1. android/guava/src/com/google/common/util/concurrent/Futures.java

        return task;
      }
    
      /**
       * Executes {@code runnable} on the specified {@code executor}, returning a {@code Future} that
       * will complete after execution.
       *
       * @throws RejectedExecutionException if the task cannot be scheduled for execution
       * @since 28.2
       */
      public static ListenableFuture<@Nullable Void> submit(Runnable runnable, Executor executor) {
        TrustedListenableFutureTask<@Nullable Void> task =
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 64.3K bytes
    - Viewed (0)
  2. okhttp/api/jvm/okhttp.api

    	public final fun getIdleCallback ()Ljava/lang/Runnable;
    	public final fun getMaxRequests ()I
    	public final fun getMaxRequestsPerHost ()I
    	public final fun queuedCalls ()Ljava/util/List;
    	public final fun queuedCallsCount ()I
    	public final fun runningCalls ()Ljava/util/List;
    	public final fun runningCallsCount ()I
    	public final fun setIdleCallback (Ljava/lang/Runnable;)V
    	public final fun setMaxRequests (I)V
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Aug 16 09:39:51 UTC 2025
    - 69.4K bytes
    - Viewed (0)
  3. okhttp/api/android/okhttp.api

    	public final fun getIdleCallback ()Ljava/lang/Runnable;
    	public final fun getMaxRequests ()I
    	public final fun getMaxRequestsPerHost ()I
    	public final fun queuedCalls ()Ljava/util/List;
    	public final fun queuedCallsCount ()I
    	public final fun runningCalls ()Ljava/util/List;
    	public final fun runningCallsCount ()I
    	public final fun setIdleCallback (Ljava/lang/Runnable;)V
    	public final fun setMaxRequests (I)V
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Aug 16 09:39:51 UTC 2025
    - 69.4K bytes
    - Viewed (0)
  4. okhttp/src/jvmTest/kotlin/okhttp3/internal/http2/HttpOverHttp2Test.kt

        sink.writeUtf8(bytes)
        sink.close()
        return bytesOut
      }
    
      internal inner class AsyncRequest(
        val path: String,
        val countDownLatch: CountDownLatch,
      ) : Runnable {
        override fun run() {
          try {
            val call =
              client.newCall(
                Request
                  .Builder()
                  .url(server.url(path))
                  .build(),
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Fri Jun 20 11:46:46 UTC 2025
    - 73.4K bytes
    - Viewed (0)
  5. guava-tests/test/com/google/common/cache/CacheLoadingTest.java

        CountDownLatch gettersComplete = new CountDownLatch(nThreads);
        for (int i = 0; i < nThreads; i++) {
          int index = i;
          Thread thread =
              new Thread(
                  new Runnable() {
                    @Override
                    public void run() {
                      gettersStartedSignal.countDown();
                      Object value = null;
                      try {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Aug 11 19:31:30 UTC 2025
    - 85.7K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/collect/MapMakerInternalMap.java

        }
    
        @Override
        void maybeClearReferenceQueues() {
          clearReferenceQueue(queueForKeys);
        }
      }
    
      static final class CleanupMapTask implements Runnable {
        final WeakReference<MapMakerInternalMap<?, ?, ?, ?>> mapReference;
    
        public CleanupMapTask(MapMakerInternalMap<?, ?, ?, ?> map) {
          this.mapReference = new WeakReference<>(map);
        }
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Aug 11 19:31:30 UTC 2025
    - 90K bytes
    - Viewed (0)
  7. cmd/xl-storage_test.go

    		t.Fatalf("Unable to create a file \"as-directory/as-file\", %s", err)
    	}
    	if err = xlStorage.AppendFile(t.Context(), "exists", "as-file/xl.meta", xlMeta); err != nil {
    		t.Fatalf("Unable to create a file \"as-file\", %s", err)
    	}
    	if err = xlStorage.AppendFile(t.Context(), "exists", "as-file-parent/xl.meta", xlMeta); err != nil {
    		t.Fatalf("Unable to create a file \"as-file-parent\", %s", err)
    	}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 66K bytes
    - Viewed (0)
  8. cmd/peer-rest-server.go

    	logger.FatalIf(getMetacacheListingRPC.Register(gm, server.GetMetacacheListingHandler), "unable to register handler")
    	logger.FatalIf(getMetricsRPC.Register(gm, server.GetMetricsHandler), "unable to register handler")
    	logger.FatalIf(getNetInfoRPC.Register(gm, server.GetNetInfoHandler), "unable to register handler")
    	logger.FatalIf(getOSInfoRPC.Register(gm, server.GetOSInfoHandler), "unable to register handler")
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Mar 30 00:56:02 UTC 2025
    - 53.4K bytes
    - Viewed (0)
  9. cmd/iam.go

    				iamLogIf(ctx, fmt.Errorf("Unable to initialize OpenID: %w", err), logger.WarningKind)
    			} else {
    				openidInit = true
    				sys.Lock()
    				sys.OpenIDConfig = openidConfig
    				sys.Unlock()
    			}
    		}
    
    		if !ldapInit {
    			// Initialize if LDAP is enabled
    			ldapConfig, err := xldap.Lookup(s, globalRootCAs)
    			if err != nil {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 75.3K bytes
    - Viewed (0)
  10. cmd/batch-handlers.go

    			for attempts <= 3 {
    				aerr := api.AbortMultipartUpload(ctx, tgtBucket, tgtObject, res.UploadID, ObjectOptions{})
    				if aerr == nil {
    					return
    				}
    				batchLogIf(ctx,
    					fmt.Errorf("trying %s: Unable to cleanup failed multipart replication %s on remote %s/%s: %w - this may consume space on remote cluster",
    						humanize.Ordinal(attempts), res.UploadID, tgtBucket, tgtObject, aerr))
    				attempts++
    				time.Sleep(time.Second)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 63.5K bytes
    - Viewed (0)
Back to top