Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 164 for CBlock (0.17 sec)

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

        Lock myLock = CycleDetectingLockFactory.newInstance(Policies.THROW).newReentrantLock("MyLock");
        lock03.lock();
        myLock.lock();
        lock03.unlock();
    
        PotentialDeadlockException expected =
            assertThrows(PotentialDeadlockException.class, () -> lock01.lock());
        checkMessage(
            expected,
            "MyLock -> OtherOrder.FIRST",
            "OtherOrder.THIRD -> MyLock",
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 16.1K bytes
    - Viewed (0)
  2. maven-core/src/main/java/org/apache/maven/lifecycle/internal/MojoExecutor.java

                }
                if (acquiredAggregatorLock != null) {
                    acquiredAggregatorLock.unlock();
                }
                mojos.remove(Thread.currentThread());
            }
    
            private OwnerReentrantLock getProjectLock(MavenSession session) {
                SessionData data = session.getSession().getData();
    Java
    - Registered: Sun Apr 28 03:35:10 GMT 2024
    - Last Modified: Wed Feb 28 23:31:09 GMT 2024
    - 20.7K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/util/concurrent/ForwardingLock.java

    import java.util.concurrent.locks.Condition;
    import java.util.concurrent.locks.Lock;
    
    /** Forwarding wrapper around a {@code Lock}. */
    @J2ktIncompatible
    @ElementTypesAreNonnullByDefault
    abstract class ForwardingLock implements Lock {
      abstract Lock delegate();
    
      @Override
      public void lock() {
        delegate().lock();
      }
    
      @Override
      public void lockInterruptibly() throws InterruptedException {
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Tue Apr 04 09:45:04 GMT 2023
    - 1.5K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/StripedTest.java

            .add(new Striped.SmallLazyStriped<ReadWriteLock>(50, READ_WRITE_LOCK_SUPPLIER))
            .add(new Striped.SmallLazyStriped<ReadWriteLock>(64, READ_WRITE_LOCK_SUPPLIER))
            .add(new Striped.LargeLazyStriped<ReadWriteLock>(50, READ_WRITE_LOCK_SUPPLIER))
            .add(new Striped.LargeLazyStriped<ReadWriteLock>(64, READ_WRITE_LOCK_SUPPLIER))
            .add(new Striped.SmallLazyStriped<Lock>(50, LOCK_SUPPLER))
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Feb 09 22:57:07 GMT 2022
    - 8.4K bytes
    - Viewed (0)
  5. guava-tests/test/com/google/common/util/concurrent/TestThread.java

     * test with reference to the same "lock-like object", and then their interactions with that object
     * are choreographed via the various methods on this class.
     *
     * <p>A "lock-like object" is really any object that may be used for concurrency control. If the
     * {@link #callAndAssertBlocks} method is ever called in a test, the lock-like object must have a
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Wed Apr 26 20:07:17 GMT 2023
    - 10.9K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/collect/MapMakerInternalMap.java

        }
    
        // reference queues, for garbage collection cleanup
    
        /** Cleanup collected entries when the lock is available. */
        void tryDrainReferenceQueues() {
          if (tryLock()) {
            try {
              maybeDrainReferenceQueues();
            } finally {
              unlock();
            }
          }
        }
    
        @GuardedBy("this")
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Mon Apr 01 16:15:01 GMT 2024
    - 91.9K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/util/concurrent/Uninterruptibles.java

          }
        }
      }
    
      /**
       * Invokes {@code lock.}{@link Lock#tryLock(long, TimeUnit) tryLock(timeout, unit)}
       * uninterruptibly.
       *
       * @since 30.0
       */
      @J2ktIncompatible
      @GwtIncompatible // concurrency
      @SuppressWarnings("GoodTime") // should accept a java.time.Duration
      public static boolean tryLockUninterruptibly(Lock lock, long timeout, TimeUnit unit) {
        boolean interrupted = false;
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Tue Apr 04 09:45:04 GMT 2023
    - 14.4K bytes
    - Viewed (0)
  8. src/main/java/jcifs/smb1/dcerpc/rpc.java

            public byte clock_seq_hi_and_reserved;
            public byte clock_seq_low;
            public byte[] node;
    
            public void encode(NdrBuffer _dst) throws NdrException {
                _dst.align(4);
                _dst.enc_ndr_long(time_low);
                _dst.enc_ndr_short(time_mid);
                _dst.enc_ndr_short(time_hi_and_version);
                _dst.enc_ndr_small(clock_seq_hi_and_reserved);
    Java
    - Registered: Sun Apr 28 00:10:09 GMT 2024
    - Last Modified: Fri Mar 22 20:39:42 GMT 2019
    - 8K bytes
    - Viewed (0)
  9. guava-tests/test/com/google/common/hash/MacHashFunctionTest.java

        byte[] key = fillByteArray(80, 0xaa);
        String data = "Test Using Larger Than Block-Size Key - Hash Key First";
    
        checkSha1("aa4ae5e15272d00e95705637ce8a3b55ed402112", key, data);
      }
    
      public void testRfc2202_hmacSha1_case7() {
        byte[] key = fillByteArray(80, 0xaa);
        String data = "Test Using Larger Than Block-Size Key and Larger Than One Block-Size Data";
    
    Java
    - Registered: Fri Apr 19 12:43:09 GMT 2024
    - Last Modified: Wed Sep 06 17:04:31 GMT 2023
    - 13.8K bytes
    - Viewed (0)
  10. src/main/java/jcifs/ntlmssp/Type2Message.java

         */
        public void setTarget ( String target ) {
            this.target = target;
        }
    
    
        /**
         * Returns the target information block.
         *
         * @return A <code>byte[]</code> containing the target information block.
         *         The target information block is used by the client to create an
         *         NTLMv2 response.
         */
        public byte[] getTargetInformation () {
    Java
    - Registered: Sun Apr 28 00:10:09 GMT 2024
    - Last Modified: Sun Jul 01 13:12:10 GMT 2018
    - 14.4K bytes
    - Viewed (0)
Back to top