Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 10 of 302 for awaiter (0.07 seconds)

  1. android/guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java

            try {
              latch.await();
            } catch (InterruptedException quittingTime) {
            }
            return TEST_STRING;
          }
        };
      }
    
      public Runnable awaiter(CountDownLatch latch) {
        return new CheckedRunnable() {
          @Override
          public void realRun() throws InterruptedException {
            await(latch);
          }
        };
      }
    
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Dec 11 20:07:52 GMT 2025
    - 37.8K bytes
    - Click Count (0)
  2. guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

        WaiterThread waiter1 = new WaiterThread(future);
        waiter1.start();
        waiter1.awaitWaiting();
    
        WaiterThread waiter2 = new WaiterThread(future);
        waiter2.start();
        waiter2.awaitWaiting();
        // The waiter queue should be waiter2->waiter1
    
        // This should wake up waiter1 and cause the waiter1 node to be removed.
        waiter1.interrupt();
    
        waiter1.join();
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Dec 11 20:45:32 GMT 2025
    - 46.8K bytes
    - Click Count (0)
  3. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java

        WaiterThread waiter1 = new WaiterThread(future);
        waiter1.start();
        waiter1.awaitWaiting();
    
        WaiterThread waiter2 = new WaiterThread(future);
        waiter2.start();
        waiter2.awaitWaiting();
        // The waiter queue should be waiter2->waiter1
    
        // This should wake up waiter1 and cause the waiter1 node to be removed.
        waiter1.interrupt();
    
        waiter1.join();
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Dec 11 20:45:32 GMT 2025
    - 46.8K bytes
    - Click Count (0)
  4. android/guava/src/com/google/common/util/concurrent/AbstractFutureState.java

      volatile @Nullable Waiter waitersField;
    
      /** Non-volatile write of the thread to the {@link Waiter#thread} field. */
      private static void putThread(Waiter waiter, Thread newValue) {
        ATOMIC_HELPER.putThread(waiter, newValue);
      }
    
      /** Non-volatile write of the waiter to the {@link Waiter#next} field. */
      private static void putNext(Waiter waiter, @Nullable Waiter newValue) {
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 33.2K bytes
    - Click Count (0)
  5. guava/src/com/google/common/util/concurrent/AbstractFutureState.java

      volatile @Nullable Waiter waitersField;
    
      /** Non-volatile write of the thread to the {@link Waiter#thread} field. */
      private static void putThread(Waiter waiter, Thread newValue) {
        ATOMIC_HELPER.putThread(waiter, newValue);
      }
    
      /** Non-volatile write of the waiter to the {@link Waiter#next} field. */
      private static void putNext(Waiter waiter, @Nullable Waiter newValue) {
    Created: Fri Dec 26 12:43:10 GMT 2025
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 34.8K bytes
    - Click Count (0)
  6. compat/maven-plugin-api/src/main/java/org/apache/maven/plugin/logging/SystemStreamLog.java

            StringWriter sWriter = new StringWriter();
            PrintWriter pWriter = new PrintWriter(sWriter);
    
            error.printStackTrace(pWriter);
    
            System.out.println("[" + prefix + "] " + sWriter);
        }
    
        private void print(String prefix, CharSequence content, Throwable error) {
            StringWriter sWriter = new StringWriter();
    Created: Sun Dec 28 03:35:09 GMT 2025
    - Last Modified: Fri Jun 06 14:28:57 GMT 2025
    - 5.3K bytes
    - Click Count (0)
  7. src/archive/tar/writer.go

    	"path"
    	"slices"
    	"strings"
    	"time"
    )
    
    // Writer provides sequential writing of a tar archive.
    // [Writer.WriteHeader] begins a new file with the provided [Header],
    // and then Writer can be treated as an io.Writer to supply that file's data.
    type Writer struct {
    	w    io.Writer
    	pad  int64      // Amount of padding to write after current file entry
    	curr fileWriter // Writer for current file entry
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Mon Feb 03 16:38:43 GMT 2025
    - 19.7K bytes
    - Click Count (0)
  8. src/archive/zip/writer.go

    // for the file metadata. [Writer] takes ownership of fh and may mutate
    // its fields. The caller must not modify fh after calling [Writer.CreateHeader].
    //
    // This returns a [Writer] to which the file contents should be written.
    // The file's contents must be written to the io.Writer before the next
    // call to [Writer.Create], [Writer.CreateHeader], [Writer.CreateRaw], or [Writer.Close].
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Tue Jan 28 04:20:09 GMT 2025
    - 19.4K bytes
    - Click Count (0)
  9. src/archive/tar/testdata/writer.tar

    Russ Cox <******@****.***> 1410149331 -0400
    Created: Tue Dec 30 11:13:12 GMT 2025
    - Last Modified: Mon Sep 08 04:08:51 GMT 2014
    - 3.5K bytes
    - Click Count (0)
  10. src/test/java/jcifs/internal/smb2/ServerMessageBlock2ResponseTest.java

                            // Ignore
                        }
                    }
                });
    
                waiter.start();
                Thread.sleep(50); // Give waiter time to start
    
                response.received();
    
                assertTrue(latch.await(500, TimeUnit.MILLISECONDS));
                assertTrue(response.isReceived());
            }
    
            @Test
    Created: Sat Dec 20 13:44:44 GMT 2025
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 19.3K bytes
    - Click Count (0)
Back to Top