Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 60 for currentThread (0.23 sec)

  1. guava-tests/test/com/google/common/util/concurrent/CallablesTest.java

      public void testRenaming() throws Exception {
        String oldName = Thread.currentThread().getName();
        final Supplier<String> newName = Suppliers.ofInstance("MyCrazyThreadName");
        Callable<@Nullable Void> callable =
            new Callable<@Nullable Void>() {
              @Override
              public @Nullable Void call() throws Exception {
                assertEquals(Thread.currentThread().getName(), newName.get());
                return null;
              }
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Tue Feb 13 14:28:25 GMT 2024
    - 5.4K bytes
    - Viewed (0)
  2. okhttp/src/main/kotlin/okhttp3/internal/-UtilJvm.kt

      }
    }
    
    internal inline fun threadName(
      name: String,
      block: () -> Unit,
    ) {
      val currentThread = Thread.currentThread()
      val oldName = currentThread.name
      currentThread.name = name
      try {
        block()
      } finally {
        currentThread.name = oldName
      }
    }
    
    /** Returns the Content-Length as reported by the response headers. */
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Tue Jan 09 12:33:05 GMT 2024
    - 10.5K bytes
    - Viewed (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/CallablesTest.java

      public void testRenaming() throws Exception {
        String oldName = Thread.currentThread().getName();
        final Supplier<String> newName = Suppliers.ofInstance("MyCrazyThreadName");
        Callable<@Nullable Void> callable =
            new Callable<@Nullable Void>() {
              @Override
              public @Nullable Void call() throws Exception {
                assertEquals(Thread.currentThread().getName(), newName.get());
                return null;
              }
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Tue Feb 13 14:28:25 GMT 2024
    - 5.4K bytes
    - Viewed (0)
  4. okhttp/src/main/kotlin/okhttp3/internal/concurrent/TaskRunner.kt

      }
    
      private fun runTask(task: Task) {
        val currentThread = Thread.currentThread()
        val oldName = currentThread.name
        currentThread.name = task.name
    
        var delayNanos = -1L
        try {
          delayNanos = task.runOnce()
        } finally {
          lock.withLock {
            afterRun(task, delayNanos)
          }
          currentThread.name = oldName
        }
      }
    
      private fun afterRun(
    Plain Text
    - Registered: Fri May 03 11:42:14 GMT 2024
    - Last Modified: Mon Apr 29 00:33:04 GMT 2024
    - 10.6K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/core/concurrent/CommonPoolUtil.java

        }
    
        public static void execute(final Runnable task) {
            ForkJoinPool.commonPool().execute(() -> {
                final Thread currentThread = Thread.currentThread();
                final ClassLoader orignal = currentThread.getContextClassLoader();
                currentThread.setContextClassLoader(CommonPoolUtil.class.getClassLoader());
                try {
                    task.run();
                } catch (final Exception e) {
    Java
    - Registered: Fri May 03 20:58:11 GMT 2024
    - Last Modified: Thu Mar 07 01:59:08 GMT 2024
    - 1.5K bytes
    - Viewed (1)
  6. maven-core/src/main/java/org/apache/maven/DefaultMaven.java

            }
    
            Collection<T> foundComponents = new LinkedHashSet<>();
            Collection<ClassLoader> scannedRealms = new HashSet<>();
    
            Thread currentThread = Thread.currentThread();
            ClassLoader originalContextClassLoader = currentThread.getContextClassLoader();
            try {
                for (MavenProject project : projects) {
                    ClassLoader projectRealm = project.getClassRealm();
    
    Java
    - Registered: Sun May 05 03:35:11 GMT 2024
    - Last Modified: Fri Apr 12 10:50:18 GMT 2024
    - 27.5K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/util/concurrent/ExecutionSequencer.java

            // longer than necessary.
            submitting = null;
          }
        }
    
        @SuppressWarnings("ShortCircuitBoolean")
        @Override
        public void run() {
          Thread currentThread = Thread.currentThread();
          if (currentThread != submitting) {
            /*
             * requireNonNull is safe because we set `task` before submitting this Runnable to an
             * Executor, and we don't null it out until here.
             */
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Thu Feb 01 21:46:34 GMT 2024
    - 22.1K bytes
    - Viewed (0)
  8. guava-tests/test/com/google/common/util/concurrent/FuturesGetUncheckedTest.java

      }
    
      @J2ktIncompatible
      @GwtIncompatible // Thread.interrupt
      public void testGetUnchecked_interrupted() {
        Thread.currentThread().interrupt();
        try {
          assertEquals("foo", getUnchecked(immediateFuture("foo")));
          assertTrue(Thread.currentThread().isInterrupted());
        } finally {
          Thread.interrupted();
        }
      }
    
      public void testGetUnchecked_cancelled() {
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Tue Feb 13 14:28:25 GMT 2024
    - 4.3K bytes
    - Viewed (0)
  9. src/test/java/org/codelibs/core/lang/ClassLoaderUtilTest.java

            final ClassLoader context = Thread.currentThread().getContextClassLoader();
            try {
                final ClassLoader cl = new URLClassLoader(new URL[0], getClass().getClassLoader());
                Thread.currentThread().setContextClassLoader(cl);
                assertThat(ClassLoaderUtil.getClassLoader(TestCase.class), is(sameInstance(cl)));
            } finally {
                Thread.currentThread().setContextClassLoader(context);
            }
        }
    Java
    - Registered: Fri May 03 20:58:11 GMT 2024
    - Last Modified: Thu Mar 07 01:59:08 GMT 2024
    - 3K bytes
    - Viewed (0)
  10. guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java

                  @Override
                  public Integer call() {
                    return Thread.currentThread().getStackTrace().length;
                  }
                },
                directExecutor());
        settableFuture.set(null);
        assertThat(getDone(stackDepthCheck))
            .isLessThan(Thread.currentThread().getStackTrace().length + 100);
      }
    
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Tue Feb 13 14:28:25 GMT 2024
    - 16.8K bytes
    - Viewed (0)
Back to top