- Sort Score
- Result 10 results
- Languages All
Results 1 - 8 of 8 for notifyAll (0.16 sec)
-
maven-core/src/main/java/org/apache/maven/lifecycle/internal/builder/multithreaded/ThreadOutputMuxer.java
currentStream.println(); currentStream.notifyAll(); } } @Override public void print(char c) { final PrintStream currentStream = getOutputStreamForCurrentThread(); synchronized (currentStream) { currentStream.print(c); currentStream.notifyAll(); } } @Override
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Wed Sep 06 08:39:32 GMT 2023 - 12.8K bytes - Viewed (0) -
okhttp/src/test/java/okhttp3/RecordingCallback.kt
responses.add(RecordedResponse(call.request(), null, null, null, e)) (this as Object).notifyAll() } @Synchronized override fun onResponse( call: Call, response: Response, ) { val body = response.body.string() responses.add(RecordedResponse(call.request(), response, null, body, null)) (this as Object).notifyAll() } /**
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 2.1K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/cache2/Relay.kt
* limitations under the License. */ package okhttp3.internal.cache2 import java.io.File import java.io.IOException import java.io.RandomAccessFile import okhttp3.internal.closeQuietly import okhttp3.internal.notifyAll import okio.Buffer import okio.ByteString import okio.ByteString.Companion.encodeUtf8 import okio.Source import okio.Timeout /**
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Mon Jan 08 01:13:22 GMT 2024 - 11.8K bytes - Viewed (0) -
maven-api-impl/src/main/java/org/apache/maven/internal/impl/model/DefaultModelTransformerContext.java
if (!set) { synchronized (this) { if (!set) { this.set = true; this.model = supplier.get(); this.notifyAll(); } } } return model; } } DefaultModelTransformerContext(ModelProcessor modelLocator) { this.modelLocator = modelLocator;
Java - Registered: Sun May 05 03:35:11 GMT 2024 - Last Modified: Fri Apr 12 10:50:18 GMT 2024 - 4K bytes - Viewed (0) -
okhttp/src/main/kotlin/okhttp3/internal/-UtilJvm.kt
@Suppress("PLATFORM_CLASS_MAPPED_TO_KOTLIN", "NOTHING_TO_INLINE") internal inline fun Any.notify() = (this as Object).notify() @Suppress("PLATFORM_CLASS_MAPPED_TO_KOTLIN", "NOTHING_TO_INLINE") internal inline fun Any.notifyAll() = (this as Object).notifyAll() internal fun <T> readFieldOrNull( instance: Any, fieldType: Class<T>, fieldName: String, ): T? { var c: Class<*> = instance.javaClass while (c != Any::class.java) {
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) -
okhttp/src/test/java/okhttp3/internal/http2/Http2ConnectionTest.kt
events.add(requestHeaders) notifyAll() return false } @Synchronized override fun onHeaders( streamId: Int, responseHeaders: List<Header>, last: Boolean, ): Boolean { assertThat(streamId).isEqualTo(2) assertThat(last).isTrue() events.add(responseHeaders) notifyAll() return false }
Plain Text - Registered: Fri May 03 11:42:14 GMT 2024 - Last Modified: Sat Apr 20 17:03:43 GMT 2024 - 75.4K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Monitor.java
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Dec 04 18:22:01 GMT 2023 - 38.6K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/MoreExecutors.java
return shutdown; } } @Override public void shutdown() { synchronized (lock) { shutdown = true; if (runningTasks == 0) { lock.notifyAll(); } } } // See newDirectExecutorService javadoc for unusual behavior of this method. @Override public List<Runnable> shutdownNow() { shutdown();
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Apr 17 16:33:44 GMT 2024 - 41.8K bytes - Viewed (0)