Search Options

Results per page
Sort
Preferred Languages
Advance

Results 201 - 210 of 345 for synchronize (0.07 sec)

  1. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/http1/Http1ExchangeCodec.kt

            writeUtf8("\r\n")
            write(source, byteCount)
            writeUtf8("\r\n")
          }
        }
    
        @Synchronized
        override fun flush() {
          if (closed) return // Don't throw; this stream might have been closed on the caller's behalf.
          socket.sink.flush()
        }
    
        @Synchronized
        override fun close() {
          if (closed) return
          closed = true
          socket.sink.writeUtf8("0\r\n\r\n")
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 17.5K bytes
    - Viewed (7)
  2. src/test/java/jcifs/smb/CriticalPerformanceTest.java

                                boolean contains = pool.contains(null); // Should handle gracefully
                                successCount.incrementAndGet();
                            } catch (Exception e) {
                                synchronized (exceptions) {
                                    exceptions.add(e);
                                }
                            }
                        }
                        long threadEnd = System.nanoTime();
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sun Aug 31 08:00:57 UTC 2025
    - 15.3K bytes
    - Viewed (0)
  3. fess-crawler/src/main/java/org/codelibs/fess/net/protocol/storage/Handler.java

             * This method creates a MinIO client using environment variables for configuration.
             * This method is synchronized to ensure thread-safe connection initialization.
             *
             * @throws IOException If the connection cannot be established
             */
            @Override
            public synchronized void connect() throws IOException {
                if (connected) {
                    return;
                }
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Thu Nov 20 08:52:56 UTC 2025
    - 11.1K 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. dbflute_fess/dfprop/littleAdjustmentMap.dfprop

        # /- - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        # o refreshMap: (NotRequired - Default map:{projectName=$$AutoDetect$$ ; requestUrl=http://localhost:8386/})
        #  If you use synchronizer and specify this property, no need to refresh(F5) your eclipse project.
        #  The projectName can be set plural names by slash '/'. e.g. sea/land
        #
        #; refreshMap = map:{
        #    ; projectName = $$AutoDetect$$
    Registered: Sat Dec 20 09:19:18 UTC 2025
    - Last Modified: Sat Jul 25 06:04:16 UTC 2015
    - 8.8K bytes
    - Viewed (0)
  6. internal/cachevalue/cache.go

    	// If NoWait is set, Get() will return the last good value,
    	// if TTL has expired but 2x TTL has not yet passed,
    	// but will fetch a new value in the background.
    	NoWait bool
    }
    
    // Cache contains a synchronized value that is considered valid
    // for a specific amount of time.
    // An Update function must be set to provide an updated value when needed.
    type Cache[T any] struct {
    	// updateFn must return an updated value.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri May 24 12:50:46 UTC 2024
    - 4.4K bytes
    - Viewed (0)
  7. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/publicsuffix/BasePublicSuffixList.kt

            val totalExceptionBytes = bufferedSource.readInt()
            publicSuffixExceptionListBytes = bufferedSource.readByteString(totalExceptionBytes.toLong())
          }
    
          synchronized(this) {
            this.bytes = publicSuffixListBytes!!
            this.exceptionBytes = publicSuffixExceptionListBytes!!
          }
        } finally {
          readCompleteLatch.countDown()
        }
      }
    
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Mon Jul 28 07:33:49 UTC 2025
    - 3.6K bytes
    - Viewed (0)
  8. compat/maven-model-builder/src/main/java/org/apache/maven/model/building/Graph.java

    /**
     * @deprecated use {@code org.apache.maven.api.services.ModelBuilder} instead
     */
    @Deprecated(since = "4.0.0")
    class Graph {
    
        final Map<String, Set<String>> graph = new LinkedHashMap<>();
    
        synchronized void addEdge(String from, String to) throws CycleDetectedException {
            if (graph.computeIfAbsent(from, l -> new HashSet<>()).add(to)) {
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Tue Feb 25 08:27:34 UTC 2025
    - 3.4K bytes
    - Viewed (0)
  9. impl/maven-core/src/test/remote-repo/org/apache/maven/plugins/maven-clean-plugin/0.1/maven-clean-plugin-0.1.jar

    nothing. false true false false false true org.apache.maven.plugin.coreit.ItMojo java per-lookup once-per-session org.apache.maven maven-plugin-api jar 2.0 org/apache/maven/plugin/coreit/ItMojo.class package org.apache.maven.plugin.coreit; public synchronized class ItMojo extends org.apache.maven.plugin.AbstractMojo { public void ItMojo(); public void execute(); } pom.xml 4.0.0 org.apache.maven.plugins maven-clean-plugin 0.1 maven-plugin Maven Integration Test Plugin A test plugin to assist testing...
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  10. android/guava-tests/test/com/google/common/cache/CacheReferencesTest.java

      static class Key {
        private final int value;
        private WeakReference<String> toString;
    
        Key(int value) {
          this.value = value;
        }
    
        @Override
        public synchronized String toString() {
          String s;
          if (toString != null) {
            s = toString.get();
            if (s != null) {
              return s;
            }
          }
          s = Integer.toString(value);
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Tue Sep 30 22:03:28 UTC 2025
    - 5.3K bytes
    - Viewed (0)
Back to top