- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 249 for isSynchronized (0.06 sec)
-
fess-crawler/src/main/java/org/codelibs/fess/crawler/util/TemporaryFileInputStream.java
* This method delegates to {@link FileInputStream#mark(int)}. * * @param readlimit the maximum limit of bytes that can be read before the mark position becomes invalid */ @Override public synchronized void mark(final int readlimit) { fileInputStream.mark(readlimit); } /** * Tests if this input stream supports the mark and reset methods.
Registered: Sun Sep 21 03:50:09 UTC 2025 - Last Modified: Sun Jul 06 02:13:03 UTC 2025 - 4.3K bytes - Viewed (0) -
compat/maven-compat/src/test/java/org/apache/maven/artifact/testutils/TestFileManager.java
} } public void markForDeletion(File toDelete) { filesToDelete.add(toDelete); warnAboutCleanup = true; } public synchronized File createTempDir() { try { Thread.sleep(20); } catch (InterruptedException e) { // ignore }
Registered: Sun Sep 07 03:35:12 UTC 2025 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 4.7K bytes - Viewed (0) -
src/main/java/jcifs/util/SmbCircuitBreaker.java
} } public synchronized void recordSuccess(long responseTimeMs) { getCurrentBucket().recordSuccess(responseTimeMs); } public synchronized void recordFailure() { getCurrentBucket().recordFailure(); } public synchronized WindowMetrics getMetrics() { long now = System.currentTimeMillis();
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 33.4K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/AbstractFutureState.java
synchronized (future) { if (future.waitersField == expect) { future.waitersField = update; return true; } return false; } } @Override boolean casListeners( AbstractFutureState<?> future, @Nullable Listener expect, Listener update) { synchronized (future) {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 33.2K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ExecutionList.java
// Lock while we check state. We must maintain the lock while adding the new pair so that // another thread can't run the list out from under us. We only add to the list if we have not // yet started execution. synchronized (this) { if (!executed) { runnables = new RunnableExecutorPair(runnable, executor, runnables); return; } }
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Sun Dec 22 03:38:46 UTC 2024 - 6.9K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/AbstractFutureState.java
synchronized (future) { if (future.waitersField == expect) { future.waitersField = update; return true; } return false; } } @Override boolean casListeners( AbstractFutureState<?> future, @Nullable Listener expect, Listener update) { synchronized (future) {
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 34.8K bytes - Viewed (0) -
src/main/java/jcifs/smb1/smb1/SmbSession.java
} synchronized SmbTransport transport() { if (transport == null) { transport = SmbTransport.getSmbTransport(address, port, localAddr, localPort, null); } return transport; } void send(final ServerMessageBlock request, final ServerMessageBlock response) throws SmbException { synchronized (transport()) { if (response != null) {
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 20.7K bytes - Viewed (0) -
src/main/java/jcifs/smb1/netbios/Lmhosts.java
* * @param host the hostname to resolve * @return the resolved NbtAddress or null if not found */ public synchronized static NbtAddress getByName(final String host) { return getByName(new Name(host, 0x20, null)); } synchronized static NbtAddress getByName(final Name name) { NbtAddress result = null; try { if (FILENAME != null) {
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 6K bytes - Viewed (0) -
src/main/java/jcifs/smb1/netbios/NbtAddress.java
} } obj = getCachedAddress(name); if (obj == null) { synchronized (LOOKUP_TABLE) { LOOKUP_TABLE.put(name, name); } } return obj; } private static void updateLookupTable(final Name name) { synchronized (LOOKUP_TABLE) { LOOKUP_TABLE.remove(name); LOOKUP_TABLE.notifyAll(); }
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 31.7K bytes - Viewed (0) -
src/main/java/jcifs/smb/DfsImpl.java
* * @see jcifs.DfsResolver#isTrustedDomain(jcifs.CIFSContext, java.lang.String) */ @Override public boolean isTrustedDomain(final CIFSContext tf, String domain) throws SmbAuthException { synchronized (this.domainsLock) { final Map<String, Map<String, CacheEntry<DfsReferralDataInternal>>> domains = getTrustedDomains(tf); if (domains == null) { return false; }
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 16 01:32:48 UTC 2025 - 29.7K bytes - Viewed (0)