Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 30 of 819 for unity (0.03 sec)

  1. android/guava/src/com/google/common/util/concurrent/Uninterruptibles.java

       * uninterruptibly.
       */
      @J2ktIncompatible
      @GwtIncompatible // concurrency
      @SuppressWarnings("GoodTime") // should accept a java.time.Duration
      public static boolean awaitUninterruptibly(CountDownLatch latch, long timeout, TimeUnit unit) {
        boolean interrupted = false;
        try {
          long remainingNanos = unit.toNanos(timeout);
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 19.8K bytes
    - Viewed (0)
  2. src/test/java/jcifs/internal/fscc/FileSystemInformationTest.java

            @DisplayName("Should decode with actual free units skipped")
            void testDecodeSkipsActualFreeUnits() throws SMBProtocolDecodingException {
                byte[] buffer = new byte[32];
                // total allocation units (8 bytes)
                buffer[4] = 0x01;
                // caller available allocation units (8 bytes)
                buffer[12] = 0x01;
                // actual free units (8 bytes) - should be skipped
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 18.1K bytes
    - Viewed (0)
  3. src/main/java/jcifs/smb1/smb1/Trans2QueryFSInformationResponse.java

            // Read total allocation units.
            info.alloc = readInt8(buffer, bufferIndex);
            bufferIndex += 8;
    
            // read caller available allocation units
            info.free = readInt8(buffer, bufferIndex);
            bufferIndex += 8;
    
            // skip actual free units
            bufferIndex += 8;
    
            info.sectPerAlloc = readInt4(buffer, bufferIndex);
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Thu Aug 14 07:14:38 UTC 2025
    - 5.1K bytes
    - Viewed (0)
  4. android/guava-testlib/src/com/google/common/util/concurrent/testing/SameThreadScheduledExecutorService.java

        public V get(long timeout, TimeUnit unit)
            throws InterruptedException, ExecutionException, TimeoutException {
          Preconditions.checkNotNull(unit, "unit must not be null!");
          return get();
        }
    
        @Override
        public long getDelay(TimeUnit unit) {
          Preconditions.checkNotNull(unit, "unit must not be null!");
          return 0;
        }
    
        @Override
        public int compareTo(Delayed other) {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:37:28 UTC 2025
    - 6.5K bytes
    - Viewed (0)
  5. guava-testlib/src/com/google/common/util/concurrent/testing/SameThreadScheduledExecutorService.java

        public V get(long timeout, TimeUnit unit)
            throws InterruptedException, ExecutionException, TimeoutException {
          Preconditions.checkNotNull(unit, "unit must not be null!");
          return get();
        }
    
        @Override
        public long getDelay(TimeUnit unit) {
          Preconditions.checkNotNull(unit, "unit must not be null!");
          return 0;
        }
    
        @Override
        public int compareTo(Delayed other) {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:37:28 UTC 2025
    - 6.5K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/util/concurrent/WrappingScheduledExecutorServiceTest.java

        TimeUnit lastUnit;
    
        void assertLastMethodCalled(String method, long delay, TimeUnit unit) {
          assertEquals(method, lastMethodCalled);
          assertEquals(delay, lastDelay);
          assertEquals(unit, lastUnit);
        }
    
        void assertLastMethodCalled(String method, long initialDelay, long delay, TimeUnit unit) {
          assertEquals(method, lastMethodCalled);
          assertEquals(initialDelay, lastInitialDelay);
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Jul 14 14:44:08 UTC 2025
    - 7.4K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/util/concurrent/ForwardingBlockingDeque.java

        delegate().putLast(e);
      }
    
      @Override
      public boolean offerFirst(E e, long timeout, TimeUnit unit) throws InterruptedException {
        return delegate().offerFirst(e, timeout, unit);
      }
    
      @Override
      public boolean offerLast(E e, long timeout, TimeUnit unit) throws InterruptedException {
        return delegate().offerLast(e, timeout, unit);
      }
    
      @Override
      public E takeFirst() throws InterruptedException {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 4.3K bytes
    - Viewed (0)
  8. guava-tests/test/com/google/common/util/concurrent/WrappingExecutorServiceTest.java

        }
        {
          MockExecutor mock = new MockExecutor();
          TimeUnit unit = SECONDS;
          long timeout = 5;
          TestExecutor testExecutor = new TestExecutor(mock);
          List<Future<String>> futures = testExecutor.invokeAll(tasks, timeout, unit);
          mock.assertMethodWithTimeout("invokeAll", timeout, unit);
          checkResults(futures);
        }
      }
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Jul 14 14:44:08 UTC 2025
    - 9.9K bytes
    - Viewed (0)
  9. guava/src/com/google/common/collect/ForwardingBlockingDeque.java

        delegate().putLast(e);
      }
    
      @Override
      public boolean offerFirst(E e, long timeout, TimeUnit unit) throws InterruptedException {
        return delegate().offerFirst(e, timeout, unit);
      }
    
      @Override
      public boolean offerLast(E e, long timeout, TimeUnit unit) throws InterruptedException {
        return delegate().offerLast(e, timeout, unit);
      }
    
      @Override
      public E takeFirst() throws InterruptedException {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 4.3K bytes
    - Viewed (0)
  10. guava/src/com/google/common/util/concurrent/WrappingScheduledExecutorService.java

      @Override
      public final ScheduledFuture<?> schedule(Runnable command, long delay, TimeUnit unit) {
        return delegate.schedule(wrapTask(command), delay, unit);
      }
    
      @Override
      public final <V extends @Nullable Object> ScheduledFuture<V> schedule(
          Callable<V> task, long delay, TimeUnit unit) {
        return delegate.schedule(wrapTask(task), delay, unit);
      }
    
      @Override
      public final ScheduledFuture<?> scheduleAtFixedRate(
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 2.4K bytes
    - Viewed (0)
Back to top