Search Options

Results per page
Sort
Preferred Languages
Advance

Results 151 - 160 of 271 for Synchronized (0.2 sec)

  1. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http/DateFormatting.kt

      if (position.index == length) {
        // STANDARD_DATE_FORMAT must match exactly; all text must be consumed, e.g. no ignored
        // non-standard trailing "+01:00". Those cases are covered below.
        return result
      }
      synchronized(BROWSER_COMPATIBLE_DATE_FORMAT_STRINGS) {
        for (i in 0 until BROWSER_COMPATIBLE_DATE_FORMAT_STRINGS.size) {
          var format: DateFormat? = BROWSER_COMPATIBLE_DATE_FORMATS[i]
          if (format == null) {
            format =
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Fri Dec 27 13:39:56 UTC 2024
    - 4.1K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureCancellationCauseTest.java

                if (name.startsWith(concurrentPackage)
                    // Use other classloader for ListenableFuture, so that the objects can interact
                    && !ListenableFuture.class.getName().equals(name)) {
                  synchronized (loadedClasses) {
                    Class<?> toReturn = loadedClasses.get(name);
                    if (toReturn == null) {
                      toReturn = super.findClass(name);
                      loadedClasses.put(name, toReturn);
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Oct 28 16:03:47 UTC 2025
    - 6.2K bytes
    - Viewed (0)
  3. android/guava/src/com/google/common/base/Enums.java

        }
        enumConstantCache.put(enumClass, result);
        return result;
      }
    
      static <T extends Enum<T>> Map<String, WeakReference<? extends Enum<?>>> getEnumConstants(
          Class<T> enumClass) {
        synchronized (enumConstantCache) {
          Map<String, WeakReference<? extends Enum<?>>> constants = enumConstantCache.get(enumClass);
          if (constants == null) {
            constants = populateCache(enumClass);
          }
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Jul 01 13:41:58 UTC 2025
    - 4.8K bytes
    - Viewed (0)
  4. src/test/java/org/codelibs/opensearch/extension/analysis/SynonymLoader.java

                lastChecked = System.currentTimeMillis();
                final long timestamp = reloadableFile.lastModified();
                if (timestamp != time) {
                    synchronized (reloadableFile) {
                        if (timestamp != lastModified) {
                            createSynonymMap(true);
                            return true;
                        }
                    }
                }
    Registered: Sat Dec 20 13:04:59 UTC 2025
    - Last Modified: Sun May 18 02:59:16 UTC 2025
    - 6.7K bytes
    - Viewed (1)
  5. src/main/java/jcifs/smb1/UniAddress.java

                    this.uhe = uhe;
                } catch (final Exception ex) {
                    this.uhe = new UnknownHostException(ex.getMessage());
                } finally {
                    synchronized (sem) {
                        sem.count--;
                        sem.notify();
                    }
                }
            }
        }
    
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 17K bytes
    - Viewed (0)
  6. src/main/java/jcifs/smb/SmbRandomAccessFile.java

                this.fp = 0L;
            } catch (final CIFSException e) {
                throw SmbException.wrap(e);
            }
        }
    
        /**
         * @return
         * @throws SmbException
         */
        synchronized SmbFileHandleImpl ensureOpen() throws CIFSException {
            // ensure file is open
            if (this.handle == null || !this.handle.isValid()) {
                // one extra acquire to keep this open till the stream is released
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 18.8K bytes
    - Viewed (0)
  7. guava-tests/test/com/google/common/util/concurrent/AggregateFutureStateFallbackAtomicHelperTest.java

     * strategies.
     *
     * <ul>
     *   <li>SafeAtomicHelper: uses Atomic FieldsUpdaters to implement synchronization
     *   <li>SynchronizedHelper: uses {@code synchronized} blocks for synchronization
     * </ul>
     *
     * To force selection of our fallback strategies we load {@link AggregateFutureState} (and all of
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue May 13 18:46:00 UTC 2025
    - 6.5K bytes
    - Viewed (0)
  8. src/main/java/jcifs/internal/smb2/lease/LeaseManager.java

             *
             * @param newState new lease state
             */
            public synchronized void updateState(int newState) {
                this.leaseState = newState;
                this.lastAccessTime = System.currentTimeMillis();
            }
    
            /**
             * Increment the epoch value
             */
            public synchronized void incrementEpoch() {
                this.epoch++;
            }
    
            /**
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 18.8K bytes
    - Viewed (0)
  9. guava-testlib/src/com/google/common/collect/testing/TestsForSetsInJavaUtil.java

            .suppressing(suppressForEnumSet())
            .createTestSuite();
      }
    
      /**
       * Tests regular NavigableSet behavior of synchronizedNavigableSet(treeSet); does not test the
       * fact that it's synchronized.
       */
      public Test testsForSynchronizedNavigableSet() {
        return NavigableSetTestSuiteBuilder.using(
                new TestStringSortedSetGenerator() {
                  @Override
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Wed Feb 19 21:24:11 UTC 2025
    - 19.8K bytes
    - Viewed (0)
  10. fess-crawler/src/test/java/org/codelibs/fess/net/protocol/gcs/HandlerTest.java

                        startLatch.await(); // Wait for signal to start
                        conn.connect();
                        successCount.incrementAndGet();
                    } catch (Exception e) {
                        synchronized (exceptions) {
                            exceptions.add(e);
                        }
                        failureCount.incrementAndGet();
                    } finally {
                        doneLatch.countDown();
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Thu Dec 11 08:38:29 UTC 2025
    - 14.1K bytes
    - Viewed (0)
Back to top