- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 109 for currentThread (0.18 sec)
-
src/main/java/org/codelibs/fess/suggest/settings/BadWordSettings.java
return; } final List<String> list = new ArrayList<>(); try (BufferedReader br = new BufferedReader(new InputStreamReader( Thread.currentThread().getContextClassLoader().getResourceAsStream("suggest_settings/default-badwords.txt")))) { String line; while ((line = br.readLine()) != null) {
Registered: Fri Nov 08 09:08:12 UTC 2024 - Last Modified: Sat Oct 12 00:10:39 UTC 2024 - 4.3K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/publicsuffix/PublicSuffixDatabase.kt
readTheListUninterruptibly() } else { try { readCompleteLatch.await() } catch (_: InterruptedException) { Thread.currentThread().interrupt() // Retain interrupted status. } } check(::publicSuffixListBytes.isInitialized) { // May have failed with an IOException
Registered: Fri Nov 01 11:42:11 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 11.7K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/ExecutionListTest.java
list.add( new Runnable() { @Override public void run() { try { okayToRun.await(); } catch (InterruptedException e) { Thread.currentThread().interrupt(); throw new RuntimeException(e); } runCalled.getAndIncrement(); } }, directExecutor()); Runnable execute =
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 22:10:29 UTC 2024 - 4.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/ExecutionListTest.java
list.add( new Runnable() { @Override public void run() { try { okayToRun.await(); } catch (InterruptedException e) { Thread.currentThread().interrupt(); throw new RuntimeException(e); } runCalled.getAndIncrement(); } }, directExecutor()); Runnable execute =
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 22:10:29 UTC 2024 - 4.7K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/service/FailureUrlService.java
failureUrl.setErrorName(errorName); failureUrl.setErrorLog(getStackTrace(e)); failureUrl.setLastAccessTime(ComponentUtil.getSystemHelper().getCurrentTimeAsLong()); failureUrl.setThreadName(Thread.currentThread().getName()); bhv.insertOrUpdate(failureUrl, op -> { op.setRefreshPolicy(Constants.TRUE); }); return failureUrl; }
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Mon Jun 24 01:20:42 UTC 2024 - 6.3K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/ProtocolHelper.java
protected void loadProtocols(final String basePackage) { final List<String> subPackages = new ArrayList<>(); final String path = basePackage.replace('.', '/'); final ClassLoader classLoader = Thread.currentThread().getContextClassLoader(); try { final Enumeration<URL> resources = classLoader.getResources(path); while (resources.hasMoreElements()) {
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Wed Jun 19 01:34:15 UTC 2024 - 7.4K bytes - Viewed (0) -
compat/maven-compat/src/test/java/org/apache/maven/project/AbstractMavenProjectTestCase.java
} protected static File getFileForClasspathResource(String resource) throws FileNotFoundException, URISyntaxException { ClassLoader cloader = Thread.currentThread().getContextClassLoader(); URL resourceUrl = cloader.getResource(resource); if (resourceUrl == null) { throw new FileNotFoundException("Unable to find: " + resource); }
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 6.9K bytes - Viewed (0) -
impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/LookupInvoker.java
Properties oldProps = (Properties) System.getProperties().clone(); ClassLoader oldCL = Thread.currentThread().getContextClassLoader(); try (C context = createContext(invokerRequest)) { try { if (context.currentThreadContextClassLoader != null) { Thread.currentThread().setContextClassLoader(context.currentThreadContextClassLoader); }
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 38K bytes - Viewed (0) -
impl/maven-cli/src/main/java/org/apache/maven/cling/invoker/mvnenc/DefaultEncryptInvoker.java
context.addInHeader("This tool is part of Apache Maven 4 distribution."); context.addInHeader(""); Thread executeThread = Thread.currentThread(); context.terminal.handle(Terminal.Signal.INT, signal -> executeThread.interrupt()); ConsolePrompt.UiConfig config; if (context.terminal.getType().equals(Terminal.TYPE_DUMB)
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 7.6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/InterruptibleTaskTest.java
new CountDownLatch(1).await(); // the interrupt will wake us up } catch (InterruptedException ie) { // continue } LockSupport.unpark(Thread.currentThread()); // simulate a spurious wakeup. return null; } @Override boolean isDone() { return false; } @Override
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 22:10:29 UTC 2024 - 6.6K bytes - Viewed (0)