Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 161 - 170 of 605 for thead (0.01 seconds)

  1. android/guava/src/com/google/common/eventbus/SubscriberRegistry.java

           * UncheckedExecutionException, which has the stack trace from this thread and which has its
           * cause set to the underlying exception (which may be from another thread). If we someday
           * learn that some other exception besides IllegalArgumentException is common, then we could
           * add another special case to throw an instance of it, too.
           */
          throw e;
        }
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue Jul 08 18:32:10 GMT 2025
    - 10.8K bytes
    - Click Count (0)
  2. guava/src/com/google/common/cache/AbstractCache.java

         */
        void recordHits(int count);
    
        /**
         * Records cache misses. This should be called when a cache request returns a value that was not
         * found in the cache. This method should be called by the loading thread, as well as by threads
         * blocking on the load. Multiple concurrent calls to {@link Cache} lookup methods with the same
         * key on an absent value should result in a single call to either {@code recordLoadSuccess} or
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue May 13 17:27:14 GMT 2025
    - 9.1K bytes
    - Click Count (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/FuturesTransformAsyncTest.java

      }
    
      public void testFutureCancellableBeforeFunctionCompletion() throws Exception {
        // Set the result in a separate thread since this test runs the function
        // (which will block) in the same thread.
        new Thread() {
          @Override
          public void run() {
            inputFuture.set(SLOW_FUNC_VALID_INPUT_DATA);
          }
        }.start();
        funcIsWaitingLatch.await();
    
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Dec 11 20:07:52 GMT 2025
    - 6.4K bytes
    - Click Count (0)
  4. guava-tests/test/com/google/common/util/concurrent/FuturesTransformAsyncTest.java

      }
    
      public void testFutureCancellableBeforeFunctionCompletion() throws Exception {
        // Set the result in a separate thread since this test runs the function
        // (which will block) in the same thread.
        new Thread() {
          @Override
          public void run() {
            inputFuture.set(SLOW_FUNC_VALID_INPUT_DATA);
          }
        }.start();
        funcIsWaitingLatch.await();
    
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Dec 11 20:07:52 GMT 2025
    - 6.4K bytes
    - Click Count (0)
  5. impl/maven-core/src/main/java/org/apache/maven/lifecycle/internal/builder/multithreaded/MultiThreadedBuilder.java

     * <p>
     * This builder uses a number of threads equal to the minimum of the degree of concurrency (which is the thread count
     * set with <code>-T</code> on the command-line) and the number of projects to build. As such, building a single project
     * will always result in a sequential build, regardless of the thread count.
     * </p>
     * <strong>NOTE:</strong> This class is not part of any public api and can be changed or deleted without prior notice.
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Wed Jul 16 03:42:09 GMT 2025
    - 8.9K bytes
    - Click Count (0)
  6. impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/PlexusContainerCapsuleFactory.java

            Thread.currentThread().setContextClassLoader(containerRealm);
            DefaultPlexusContainer container = new DefaultPlexusContainer(cc, getCustomModule(context, exports));
    
            // NOTE: To avoid inconsistencies, we'll use the TCCL exclusively for lookups
            container.setLookupRealm(null);
            Thread.currentThread().setContextClassLoader(container.getContainerRealm());
    
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Thu Jul 03 14:18:26 GMT 2025
    - 14.3K bytes
    - Click Count (0)
  7. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/-UtilJvm.kt

    /** Dispatcher is not [Lockable] because we don't want that type in our public API. */
    internal fun Dispatcher.assertLockNotHeld() {
      if (assertionsEnabled && Thread.holdsLock(this)) {
        throw AssertionError("Thread ${Thread.currentThread().name} MUST NOT hold lock on $this")
      }
    }
    
    /**
     * Returns the string "OkHttp" unless the library has been shaded for inclusion in another library,
    Created: Fri Dec 26 11:42:13 GMT 2025
    - Last Modified: Thu Jul 31 04:18:40 GMT 2025
    - 10.2K bytes
    - Click Count (1)
  8. guava-tests/test/com/google/common/util/concurrent/AbstractFutureFallbackAtomicHelperTest.java

        ClassLoader oldClassLoader = Thread.currentThread().getContextClassLoader();
    
        Thread.currentThread().setContextClassLoader(classLoader);
        try {
          Class<?> test = classLoader.loadClass(AbstractFutureTest.class.getName());
          test.getMethod(getName()).invoke(test.getDeclaredConstructor().newInstance());
        } finally {
          Thread.currentThread().setContextClassLoader(oldClassLoader);
        }
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Tue May 13 18:46:00 GMT 2025
    - 7.3K bytes
    - Click Count (0)
  9. compat/maven-compat/src/main/java/org/apache/maven/artifact/resolver/DefaultArtifactResolver.java

            static final ThreadGroup GROUP = new ThreadGroup(THREADGROUP_NAME);
    
            static final AtomicInteger THREAD_NUMBER = new AtomicInteger(1);
    
            @Override
            public Thread newThread(Runnable r) {
                Thread newThread = new Thread(GROUP, r, "resolver-" + THREAD_NUMBER.getAndIncrement());
                newThread.setDaemon(true);
                newThread.setContextClassLoader(null);
                return newThread;
            }
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Fri Jun 06 14:28:57 GMT 2025
    - 25K bytes
    - Click Count (0)
  10. .github/workflows/validate-codeowners.yml

        steps:
          - name: Get Secrets
            uses: gradle/actions-internal/get-aws-secrets@v1
            if: (github.event_name != 'pull_request' && github.repository_owner == 'gradle') || github.event.pull_request.head.repo.full_name == github.repository
            with:
              role-to-assume: arn:aws:iam::992382829881:role/GHASecrets_gradle_all
              secret-ids: |
    Created: Wed Dec 31 11:36:14 GMT 2025
    - Last Modified: Thu Nov 20 22:15:20 GMT 2025
    - 1.5K bytes
    - Click Count (0)
Back to Top