- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of 284 for Synchronized (0.04 sec)
-
samples/slack/src/main/java/okhttp3/slack/OAuthSessionFactory.java
} public HttpUrl newAuthorizeUrl(String scopes, String team, Listener listener) { if (mockWebServer == null) throw new IllegalStateException(); ByteString state = randomToken(); synchronized (this) { listeners.put(state, listener); } return slackApi.authorizeUrl(scopes, redirectUrl(), state, team); } private ByteString randomToken() { byte[] bytes = new byte[16];
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Thu Aug 12 07:26:27 UTC 2021 - 3.8K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/dict/stemmeroverride/StemmerOverrideFile.java
} @Override public synchronized void insert(final StemmerOverrideItem item) { try (StemmerOverrideUpdater updater = new StemmerOverrideUpdater(item)) { reload(updater); } } @Override public synchronized void update(final StemmerOverrideItem item) {
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 13.7K bytes - Viewed (0) -
android/guava-tests/benchmark/com/google/common/util/concurrent/ExecutionListBenchmark.java
synchronized (this) { if (!executed) { runnables = new RunnableExecutorPair(runnable, executor, runnables); return; } } executeListener(runnable, executor); } void execute() { RunnableExecutorPair list; synchronized (this) { if (executed) { return; }
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Wed Jul 16 17:42:14 UTC 2025 - 15.8K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/suggest/concurrent/Deferred.java
* Resolves the deferred computation with the given response. * @param r The response. */ public void resolve(final RESPONSE r) { final ArrayList<Consumer<RESPONSE>> executeCallbacks; synchronized (Deferred.this) { if (response != null || error != null) { return; } response = r; executeCallbacks = new ArrayList<>(doneCallbacks.size());
Registered: Fri Sep 19 09:08:11 UTC 2025 - Last Modified: Fri Jul 04 14:00:23 UTC 2025 - 7.8K bytes - Viewed (0) -
src/main/java/jcifs/smb/SmbTransportImpl.java
} } } protected synchronized void doDisconnect(final boolean hard) throws IOException { doDisconnect(hard, false); } @Override protected synchronized boolean doDisconnect(final boolean hard, final boolean inUse) throws IOException {
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Sat Aug 30 05:58:03 UTC 2025 - 69.8K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/RecordingCallback.kt
*/ class RecordingCallback : Callback { private val responses = mutableListOf<RecordedResponse>() @Synchronized override fun onFailure( call: Call, e: IOException, ) { responses.add(RecordedResponse(call.request(), null, null, null, e)) (this as Object).notifyAll() } @Synchronized override fun onResponse( call: Call, response: Response, ) {
Registered: Fri Sep 05 11:42:10 UTC 2025 - Last Modified: Fri Dec 27 13:39:56 UTC 2024 - 2.1K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ListenerCallQueue.java
enqueueHelper(event, label); } private void enqueueHelper(Event<L> event, Object label) { checkNotNull(event, "event"); checkNotNull(label, "label"); synchronized (listeners) { for (PerListenerQueue<L> queue : listeners) { queue.add(event, label); } } } /**
Registered: Fri Sep 05 12:43:10 UTC 2025 - Last Modified: Tue May 13 17:27:14 UTC 2025 - 8.1K bytes - Viewed (0) -
src/main/java/jcifs/smb1/smb1/SmbTree.java
return matches(tree.share, tree.service); } return false; } void send(final ServerMessageBlock request, final ServerMessageBlock response) throws SmbException { synchronized (session.transport()) { if (response != null) { response.received = false; } treeConnect(request, response);
Registered: Sun Sep 07 00:10:21 UTC 2025 - Last Modified: Thu Aug 14 07:14:38 UTC 2025 - 8.1K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/dict/mapping/CharMappingFile.java
* @param size the maximum number of items to return * @return a PagingList containing the requested subset of mapping items */ @Override public synchronized PagingList<CharMappingItem> selectList(final int offset, final int size) { if (mappingItemList == null) { reload(null); } if (offset >= mappingItemList.size() || offset < 0) {
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 14.9K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/dict/kuromoji/KuromojiFile.java
} @Override public synchronized void insert(final KuromojiItem item) { try (KuromojiUpdater updater = new KuromojiUpdater(item)) { reload(updater); } } @Override public synchronized void update(final KuromojiItem item) { try (KuromojiUpdater updater = new KuromojiUpdater(item)) {
Registered: Thu Sep 04 12:52:25 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 11.3K bytes - Viewed (0)