- Sort Score
- Result 10 results
- Languages All
Results 51 - 60 of 362 for synchronised (0.36 sec)
-
platforms/core-runtime/daemon-services/src/main/java/org/gradle/api/internal/tasks/userinput/DefaultUserInputReader.java
private UserInput pending; private boolean finished; @Override public void startInput() { synchronized (lock) { pending = null; finished = false; } } @Override public void putInput(UserInput input) { synchronized (lock) { if (input == END_OF_INPUT) { finished = true; lock.notifyAll();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 09 04:50:46 UTC 2024 - 2.1K bytes - Viewed (0) -
platforms/core-configuration/model-core/src/main/java/org/gradle/model/internal/manage/schema/extract/DefaultModelSchemaStore.java
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Sep 28 09:51:04 UTC 2023 - 1.9K bytes - Viewed (0) -
platforms/core-runtime/daemon-services/src/main/java/org/gradle/internal/daemon/clientinput/StdInStream.java
} } } @Override public void close() { synchronized (lock) { // Allow threads to read anything still buffered closed = true; lock.notifyAll(); } } public void received(byte[] bytes) { synchronized (lock) { if (!waiting) { throw new IllegalStateException(); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 15 19:51:37 UTC 2024 - 3.1K bytes - Viewed (0) -
src/main/java/jcifs/smb1/netbios/SocketInputStream.java
Registered: Wed Jun 12 15:45:55 UTC 2024 - Last Modified: Fri Mar 22 20:39:42 UTC 2019 - 3.3K bytes - Viewed (0) -
android/guava/src/com/google/common/io/FileBackedOutputStream.java
} } } } @Override public synchronized void write(int b) throws IOException { update(1); out.write(b); } @Override public synchronized void write(byte[] b) throws IOException { write(b, 0, b.length); } @Override public synchronized void write(byte[] b, int off, int len) throws IOException { update(len);
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 22 17:40:56 UTC 2024 - 8.2K bytes - Viewed (0) -
src/main/java/jcifs/smb1/smb1/BufferCache.java
} } static void getBuffers( SmbComTransaction req, SmbComTransactionResponse rsp ) { synchronized( cache ) { req.txn_buf = getBuffer(); rsp.txn_buf = getBuffer(); } } static public void releaseBuffer( byte[] buf ) { synchronized( cache ) { if (freeBuffers < MAX_BUFFERS) { for (int i = 0; i < MAX_BUFFERS; i++) {
Registered: Wed Jun 12 15:45:55 UTC 2024 - Last Modified: Fri Mar 22 21:10:40 UTC 2019 - 2.2K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/bbottema/javasocksproxyserver/TestRecordingSocksServer.java
} public synchronized void start(int listenPort) { start(listenPort, ServerSocketFactory.getDefault()); } public synchronized void start(int listenPort, ServerSocketFactory serverSocketFactory) { this.stopping = false; new Thread(new ServerProcess(listenPort, serverSocketFactory)).start(); } public synchronized void stop() { stopping = true; }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 4.7K bytes - Viewed (0) -
okhttp/src/test/java/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: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Jan 08 01:13:22 UTC 2024 - 2.1K 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: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 9.7K bytes - Viewed (0) -
guava-testlib/src/com/google/common/testing/TestLogHandler.java
/** Adds the most recently logged record to our list. */ @Override public synchronized void publish(@Nullable LogRecord record) { if (record != null) { list.add(record); } } @Override public void flush() {} @Override public void close() {} public synchronized void clear() { list.clear(); } /** Returns a snapshot of the logged records. */ /*
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Apr 26 20:07:17 UTC 2023 - 2.6K bytes - Viewed (0)