Search Options

Results per page
Sort
Preferred Languages
Advance

Results 2311 - 2320 of 2,532 for created (0.06 sec)

  1. okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskRunner.kt

       * expect a newly-started thread to call [Runnable.run]. We shouldn't request new threads until
       * the already-requested ones are in service, otherwise we might create more threads than we need.
       *
       * We use [executeCallCount] and [runCallCount] to defend against starting more threads than we
       * need. Both fields are guarded by [lock].
       */
      private var executeCallCount = 0
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Mon Apr 29 00:33:04 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  2. android/guava/src/com/google/common/collect/DenseImmutableTable.java

      }
    
      @Override
      @J2ktIncompatible // serialization
      @GwtIncompatible // serialization
      Object writeReplace() {
        return SerializedForm.create(this, cellRowIndices, cellColumnIndices);
      }
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:05:46 UTC 2024
    - 10.1K bytes
    - Viewed (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java

        }
      }
    
      public void testRejectedExecutionThrownWithMultipleCalls() throws Exception {
        final CountDownLatch latch = new CountDownLatch(1);
        final SettableFuture<?> future = SettableFuture.create();
        final Executor delegate =
            new Executor() {
              @Override
              public void execute(Runnable task) {
                if (future.set(null)) {
                  awaitUninterruptibly(latch);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 11.4K bytes
    - Viewed (0)
  4. common-protos/k8s.io/api/rbac/v1/generated.proto

    // AggregationRule describes how to locate ClusterRoles to aggregate into the ClusterRole
    message AggregationRule {
      // ClusterRoleSelectors holds a list of selectors which will be used to find ClusterRoles and create the rules.
      // If any of the selectors match, then the ClusterRole's permissions will be added
      // +optional
      repeated k8s.io.apimachinery.pkg.apis.meta.v1.LabelSelector clusterRoleSelectors = 1;
    }
    
    Registered: Wed Nov 06 22:53:10 UTC 2024
    - Last Modified: Mon Mar 11 18:43:24 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  5. test-site/activator

    ###  ------------------------------- ###
    usage() {
     cat <<EOM
    Usage: $script_name <command> [options]
    
      Command:
      ui                 Start the Activator UI
      new [name] [template-id]  Create a new project with [name] using template [template-id]
      list-templates     Print all available template names
      -h | -help         Print this message
    
      Options:
      -v | -verbose      Make this runner chattier
    Registered: Fri Nov 08 09:08:12 UTC 2024
    - Last Modified: Mon Apr 20 08:41:37 UTC 2015
    - 9.3K bytes
    - Viewed (0)
  6. docs/select/README.md

    (*) Parquet is disabled on the MinIO server by default. See below how to enable it.
    
    ## Enabling Parquet Format
    
    Parquet is DISABLED by default since hostile crafted input can easily crash the server.
    
    If you are in a controlled environment where it is safe to assume no hostile content can be uploaded to your cluster you can safely enable Parquet.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 29 04:28:45 UTC 2022
    - 6.5K bytes
    - Viewed (0)
  7. impl/maven-core/src/main/java/org/apache/maven/execution/MavenSession.java

        // Backward compat
    
        /**
         * Returns the plugin context for given key ({@link PluginDescriptor#getPluginLookupKey()} and
         * {@link MavenProject}, never returns {@code null} as if context not present, creates it.
         *
         * <strong>Implementation note:</strong> while this method return type is {@link Map}, the returned map instance
         * implements {@link ConcurrentMap} as well.
         *
         */
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 16.6K bytes
    - Viewed (0)
  8. internal/grid/manager.go

    	Dialer       ConnDialer
    	// Sign a token for the given audience.
    	AuthFn AuthFn
    	// Callbacks to validate incoming connections.
    	AuthToken ValidateTokenFn
    }
    
    // NewManager creates a new grid manager
    func NewManager(ctx context.Context, o ManagerOptions) (*Manager, error) {
    	found := false
    	if o.AuthToken == nil {
    		return nil, fmt.Errorf("grid: AuthToken not set")
    	}
    	if o.Dialer == nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jul 29 18:10:04 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/job/GenerateThumbnailJob.java

            cleanup = true;
            return this;
        }
    
        @Override
        public String execute() {
            final StringBuilder resultBuf = new StringBuilder();
    
            if (sessionId == null) { // create session id
                sessionId = RandomStringUtils.randomAlphabetic(15);
            }
            resultBuf.append("Session Id: ").append(sessionId).append("\n");
            if (jobExecutor != null) {
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Fri Oct 11 21:20:39 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/util/concurrent/TimeoutFuture.java

     */
    @J2ktIncompatible
    @GwtIncompatible
    @ElementTypesAreNonnullByDefault
    final class TimeoutFuture<V extends @Nullable Object> extends FluentFuture.TrustedFuture<V> {
      static <V extends @Nullable Object> ListenableFuture<V> create(
          ListenableFuture<V> delegate,
          long time,
          TimeUnit unit,
          ScheduledExecutorService scheduledExecutor) {
        TimeoutFuture<V> result = new TimeoutFuture<>(delegate);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 25 13:13:32 UTC 2024
    - 8.1K bytes
    - Viewed (0)
Back to top