Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 131 - 140 of 326 for synchronize (0.09 seconds)

  1. src/main/java/jcifs/smb1/http/Handler.java

         *
         * @param factory The URL stream handler factory.
         */
        public static void setURLStreamHandlerFactory(final URLStreamHandlerFactory factory) {
            synchronized (PROTOCOL_HANDLERS) {
                if (Handler.factory != null) {
                    throw new IllegalStateException("URLStreamHandlerFactory already set.");
                }
                PROTOCOL_HANDLERS.clear();
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 6.1K bytes
    - Click Count (0)
  2. src/main/java/jcifs/smb/PreauthIntegrityService.java

                return hashAlgorithm;
            }
    
            public byte[] getCurrentHash() {
                synchronized (hashLock) {
                    return currentHash.clone();
                }
            }
    
            public void updateHash(byte[] newHash) {
                synchronized (hashLock) {
                    if (newHash != null && newHash.length == currentHash.length) {
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sun Aug 31 08:00:57 GMT 2025
    - 12.1K bytes
    - Click Count (0)
  3. src/main/java/jcifs/context/SingletonContext.java

         *
         * @param props the properties to use for initialization
         * @throws CIFSException if the singleton context is already initialized or there is an error during initialization
         */
        public static synchronized final void init(final Properties props) throws CIFSException {
            if (INSTANCE != null) {
                throw new CIFSException("Singleton context is already initialized");
            }
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 4.3K bytes
    - Click Count (0)
  4. src/main/java/org/codelibs/fess/helper/CrawlingInfoHelper.java

        }
    
        /**
         * Adds a key-value pair to the information map.
         * Initializes the info map as a synchronized LinkedHashMap if it doesn't exist.
         *
         * @param key the parameter key to store
         * @param value the parameter value to store
         */
        public synchronized void putToInfoMap(final String key, final String value) {
            if (infoMap == null) {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Aug 07 03:06:29 GMT 2025
    - 15.2K bytes
    - Click Count (0)
  5. android/guava-tests/test/com/google/common/collect/MultimapsTest.java

        Multimap<K, V> multimap = synchronizedMultimap(HashMultimap.<K, V>create());
        Collection<V> values = multimap.get(key); // Needn't be in synchronized block
        synchronized (multimap) { // Synchronizing on multimap, not values!
          Iterator<V> i = values.iterator(); // Must be in synchronized block
          while (i.hasNext()) {
            foo(i.next());
          }
        }
      }
    
      private static void foo(Object unused) {}
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Mar 13 13:01:07 GMT 2026
    - 39.2K bytes
    - Click Count (0)
  6. guava-tests/test/com/google/common/collect/SynchronizedTableTest.java

          delegate.clear();
        }
    
        @Override
        public Collection<V> values() {
          assertTrue(Thread.holdsLock(mutex));
          /* TODO: verify that the Collection is also synchronized? */
          return delegate.values();
        }
    
        @Override
        public Set<Cell<R, C, V>> cellSet() {
          assertTrue(Thread.holdsLock(mutex));
          return delegate.cellSet();
        }
    
        @Override
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Jul 16 17:42:14 GMT 2025
    - 4.7K bytes
    - Click Count (0)
  7. src/main/java/jcifs/smb1/smb1/TransactNamedPipeInputStream.java

            lock = new Object();
        }
    
        @Override
        public int read() throws IOException {
            int result = -1;
    
            synchronized (lock) {
                try {
                    while (used == 0) {
                        lock.wait();
                    }
                } catch (final InterruptedException ie) {
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 07:14:38 GMT 2025
    - 4.6K bytes
    - Click Count (0)
  8. src/main/java/jcifs/smb/NtlmAuthenticator.java

         * this metho again will have no effect.
         *
         * @param a the authenticator to set as default
         */
    
        public synchronized static void setDefault(final NtlmAuthenticator a) {
            if (auth != null) {
                return;
            }
            auth = a;
        }
    
        /**
         * Gets the default NTLM authenticator.
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 01:32:48 GMT 2025
    - 4.4K bytes
    - Click Count (0)
  9. android/guava-tests/test/com/google/common/util/concurrent/AbstractServiceTest.java

          completionLatch.await();
          synchronized (this) {
            return ImmutableList.copyOf(stateHistory);
          }
        }
    
        @Override
        public synchronized void starting() {
          assertTrue(stateHistory.isEmpty());
          assertThat(service.state()).isNotEqualTo(State.NEW);
          stateHistory.add(State.STARTING);
        }
    
        @Override
        public synchronized void running() {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 28.7K bytes
    - Click Count (0)
  10. guava-tests/test/com/google/common/util/concurrent/AbstractServiceTest.java

          completionLatch.await();
          synchronized (this) {
            return ImmutableList.copyOf(stateHistory);
          }
        }
    
        @Override
        public synchronized void starting() {
          assertTrue(stateHistory.isEmpty());
          assertThat(service.state()).isNotEqualTo(State.NEW);
          stateHistory.add(State.STARTING);
        }
    
        @Override
        public synchronized void running() {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 28.7K bytes
    - Click Count (0)
Back to Top