Search Options

Results per page
Sort
Preferred Languages
Advance

Results 471 - 480 of 767 for Block (0.03 sec)

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

       *
       * Lock lockA = factory1.newReentrantLock(MyLockOrder.FIRST);
       * Lock lockB = factory1.newReentrantLock(MyLockOrder.FIRST);
       * Lock lockC = factory2.newReentrantLock(MyLockOrder.FIRST);
       *
       * lockA.lock();
       *
       * lockB.lock();  // will throw an IllegalStateException
       * lockC.lock();  // will throw an IllegalStateException
       *
       * lockA.lock();  // reentrant acquisition is okay
       * }
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Sep 11 17:06:34 UTC 2025
    - 35.9K bytes
    - Viewed (0)
  2. api/maven-api-core/src/main/java/org/apache/maven/api/MonotonicClock.java

    package org.apache.maven.api;
    
    import java.time.Clock;
    import java.time.Duration;
    import java.time.Instant;
    import java.time.ZoneId;
    import java.time.ZoneOffset;
    
    /**
     * A Clock implementation that combines monotonic timing with wall-clock time.
     * <p>
     * This class provides precise time measurements using {@link System#nanoTime()}
     * while maintaining wall-clock time information in UTC. The wall-clock time
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Wed Jan 15 06:28:29 UTC 2025
    - 5.6K bytes
    - Viewed (0)
  3. internal/config/identity/openid/jwt.go

    		if err != nil {
    			return err
    		}
    		pk.add(key.Kid, pkey)
    	}
    
    	return nil
    }
    
    func (pk *publicKeys) add(keyID string, key any) {
    	pk.Lock()
    	defer pk.Unlock()
    
    	pk.pkMap[keyID] = key
    }
    
    func (pk *publicKeys) get(kid string) any {
    	pk.RLock()
    	defer pk.RUnlock()
    	return pk.pkMap[kid]
    }
    
    // PopulatePublicKey - populates a new publickey from the JWKS URL.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 8.4K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/util/concurrent/AbstractScheduledService.java

         * always under a lock.
         */
        private static final class SupplantableFuture implements Cancellable {
          private final ReentrantLock lock;
    
          @GuardedBy("lock")
          private Future<@Nullable Void> currentFuture;
    
          SupplantableFuture(ReentrantLock lock, Future<@Nullable Void> currentFuture) {
            this.lock = lock;
            this.currentFuture = currentFuture;
          }
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 27.7K bytes
    - Viewed (0)
  5. okhttp-idna-mapping-table/src/main/resources/okhttp3/internal/idna/IdnaMappingTable.txt

    1FB00..1FB92  ; valid                  ;      ; NV8    # 13.0 BLOCK SEXTANT-1..UPPER HALF INVERSE MEDIUM SHADE AND LOWER HALF BLOCK
    1FB93         ; disallowed                             # NA   <reserved-1FB93>
    1FB94..1FBCA  ; valid                  ;      ; NV8    # 13.0 LEFT HALF INVERSE MEDIUM SHADE AND RIGHT HALF BLOCK..WHITE UP-POINTING CHEVRON
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Sat Feb 10 11:25:47 UTC 2024
    - 854.1K bytes
    - Viewed (0)
  6. api/maven-api-core/src/test/java/org/apache/maven/api/MonotonicClockTest.java

        void testClockTimezone() {
            MonotonicClock clock = MonotonicClock.get();
    
            assertEquals(ZoneOffset.UTC, clock.getZone(), "Clock should use UTC timezone");
    
            // Verify that attempting to change timezone returns the same instance
            Clock newClock = clock.withZone(ZoneId.systemDefault());
            assertSame(clock, newClock, "withZone() should return the same clock instance");
        }
    
        @Test
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Wed Jan 15 06:28:29 UTC 2025
    - 5.8K bytes
    - Viewed (0)
  7. android/guava/src/com/google/common/util/concurrent/DirectExecutorService.java

       */
      @GuardedBy("lock")
      private int runningTasks = 0;
    
      @GuardedBy("lock")
      private boolean shutdown = false;
    
      @Override
      public void execute(Runnable command) {
        startTask();
        try {
          command.run();
        } finally {
          endTask();
        }
      }
    
      @Override
      public boolean isShutdown() {
        synchronized (lock) {
          return shutdown;
        }
      }
    
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Dec 16 14:23:59 UTC 2025
    - 3.4K bytes
    - Viewed (0)
  8. android/guava-tests/test/com/google/common/util/concurrent/CycleDetectingLockFactoryTest.java

        final Lock lock;
    
        LockingThread(Lock lock) {
          this.lock = lock;
        }
    
        @Override
        public void run() {
          lock.lock();
          try {
            locked.countDown();
            finishLatch.await(1, MINUTES);
          } catch (InterruptedException e) {
            fail(e.toString());
          } finally {
            lock.unlock();
          }
        }
    
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Thu Dec 19 18:03:30 UTC 2024
    - 16.2K bytes
    - Viewed (0)
  9. internal/lock/lock_solaris.go

    			Op:   "open",
    			Path: path,
    			Err:  syscall.EINVAL,
    		}
    	}
    
    	lock := syscall.Flock_t{
    		Start:  0,
    		Len:    0,
    		Pid:    0,
    		Type:   lockType,
    		Whence: 0,
    	}
    
    	f, err := os.OpenFile(path, flag, perm)
    	if err != nil {
    		return nil, err
    	}
    
    	if err = syscall.FcntlFlock(f.Fd(), rlockType, &lock); err != nil {
    		f.Close()
    		if err == syscall.EAGAIN {
    			err = ErrAlreadyLocked
    		}
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Jan 02 17:15:06 UTC 2022
    - 2.8K bytes
    - Viewed (0)
  10. src/main/java/jcifs/internal/smb2/lease/DirectoryCacheEntry.java

                }
            } finally {
                lock.writeLock().unlock();
            }
        }
    
        /**
         * Remove a child entry
         *
         * @param childName child file name
         */
        public void removeChild(String childName) {
            lock.writeLock().lock();
            try {
                if (children.remove(childName) != null) {
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 23 02:21:31 UTC 2025
    - 11.4K bytes
    - Viewed (0)
Back to top