Search Options

Results per page
Sort
Preferred Languages
Advance

Results 11 - 20 of 96 for currentThread (0.17 sec)

  1. 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)
  2. android/guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java

              @Override
              public void run() {
                Thread.currentThread().interrupt();
              }
            });
        // Run a task that expects that it is not interrupted while it is running.
        e.execute(
            new Runnable() {
              @Override
              public void run() {
                assertThat(Thread.currentThread().isInterrupted()).isFalse();
              }
            });
    
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 11.4K bytes
    - Viewed (0)
  3. 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)
  4. android/guava-tests/test/com/google/common/util/concurrent/GeneratedMonitorTest.java

        assertFalse(Thread.currentThread().isInterrupted());
        assertFalse(monitor.isOccupiedByCurrentThread());
    
        doEnterScenarioSetUp();
    
        boolean interruptedBeforeCall = Thread.currentThread().isInterrupted();
        Outcome actualOutcome = doCall();
        boolean occupiedAfterCall = monitor.isOccupiedByCurrentThread();
        boolean interruptedAfterCall = Thread.currentThread().isInterrupted();
    
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Mon Apr 17 14:48:57 GMT 2023
    - 26.1K bytes
    - Viewed (0)
  5. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureCancellationCauseTest.java

                    }
                    return toReturn;
                  }
                }
                return super.loadClass(name);
              }
            };
        oldClassLoader = Thread.currentThread().getContextClassLoader();
        Thread.currentThread().setContextClassLoader(classReloader);
        abstractFutureClass = classReloader.loadClass(AbstractFuture.class.getName());
        settableFutureClass = classReloader.loadClass(SettableFuture.class.getName());
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 6.1K bytes
    - Viewed (0)
  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-tests/test/com/google/common/util/concurrent/FuturesGetCheckedTest.java

        SettableFuture<String> future = SettableFuture.create();
        Thread.currentThread().interrupt();
        try {
          getChecked(future, TwoArgConstructorException.class);
          fail();
        } catch (TwoArgConstructorException expected) {
          assertThat(expected).hasCauseThat().isInstanceOf(InterruptedException.class);
          assertTrue(Thread.currentThread().isInterrupted());
        } finally {
          Thread.interrupted();
        }
      }
    Java
    - Registered: Fri May 03 12:43:13 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 16.4K bytes
    - Viewed (0)
  8. guava-tests/test/com/google/common/util/concurrent/AbstractFutureCancellationCauseTest.java

                    }
                    return toReturn;
                  }
                }
                return super.loadClass(name);
              }
            };
        oldClassLoader = Thread.currentThread().getContextClassLoader();
        Thread.currentThread().setContextClassLoader(classReloader);
        abstractFutureClass = classReloader.loadClass(AbstractFuture.class.getName());
        settableFutureClass = classReloader.loadClass(SettableFuture.class.getName());
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 6.1K bytes
    - Viewed (0)
  9. guava-tests/test/com/google/common/io/ResourcesTest.java

        ClassLoader oldContextLoader = Thread.currentThread().getContextClassLoader();
        try {
          Thread.currentThread().setContextClassLoader(loader);
          URL url = Resources.getResource(tempFile.getName());
          String text = Resources.toString(url, Charsets.UTF_8);
          assertEquals("rud a chur ar an méar fhada" + System.lineSeparator(), text);
        } finally {
          Thread.currentThread().setContextClassLoader(oldContextLoader);
        }
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 6.8K bytes
    - Viewed (0)
  10. guava-tests/test/com/google/common/util/concurrent/AggregateFutureStateFallbackAtomicHelperTest.java

        // certain core jdk classes.
        ClassLoader oldClassLoader = Thread.currentThread().getContextClassLoader();
        Thread.currentThread().setContextClassLoader(NO_ATOMIC_FIELD_UPDATER);
        try {
          runTestMethod(NO_ATOMIC_FIELD_UPDATER);
          // TODO(lukes): assert that the logs are full of errors
        } finally {
          Thread.currentThread().setContextClassLoader(oldClassLoader);
        }
      }
    
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Mon Oct 10 19:45:10 GMT 2022
    - 5.9K bytes
    - Viewed (0)
Back to top