Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 261 - 270 of 344 for synchronized (0.1 seconds)

  1. src/main/java/org/codelibs/fess/helper/SystemHelper.java

         */
        protected short getSystemCpuPercent() {
            final long now = getCurrentTimeAsLong();
            if (now - systemCpuCheckTime > systemCpuCheckInterval) {
                synchronized (this) {
                    if (now - systemCpuCheckTime > systemCpuCheckInterval) {
                        try {
                            final OsProbe osProbe = OsProbe.getInstance();
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Mar 28 06:59:19 GMT 2026
    - 43.2K bytes
    - Click Count (0)
  2. guava-tests/test/com/google/common/reflect/InvokableTest.java

          assertThat(invokable.getName()).isEqualTo(name);
          assertEquals(A.class, invokable.getDeclaringClass());
          return invokable;
        }
    
        native void nativeMethod();
    
        synchronized void synchronizedMethod() {}
      }
    
      public void testConstructor_returnType() throws Exception {
        assertEquals(Prepender.class, Prepender.constructor().getReturnType().getType());
      }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 12 17:47:10 GMT 2026
    - 31.1K bytes
    - Click Count (0)
  3. src/main/java/jcifs/smb1/smb1/ServerMessageBlock.java

        static void writeUTime(long t, final byte[] dst, final int dstIndex) {
            if (t == 0L || t == 0xFFFFFFFFFFFFFFFFL) {
                writeInt4(0xFFFFFFFF, dst, dstIndex);
                return;
            }
            synchronized (TZ) {
                if (TZ.inDaylightTime(new Date())) {
                    // in DST
                    if (TZ.inDaylightTime(new Date(t))) {
                        // t also in DST so no correction
                    } else {
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 07:14:38 GMT 2025
    - 19.7K bytes
    - Click Count (0)
  4. android/guava-tests/test/com/google/common/collect/MultimapsCollectionTest.java

                          multimap.put(entry.getKey(), entry.getValue());
                        }
                        return multimap;
                      }
                    })
                .named("synchronized ArrayListMultimap")
                .withFeatures(
                    MapFeature.ALLOWS_NULL_KEYS,
                    MapFeature.ALLOWS_NULL_VALUES,
                    MapFeature.ALLOWS_ANY_NULL_QUERIES,
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Sep 24 22:52:18 GMT 2025
    - 28.4K bytes
    - Click Count (0)
  5. src/main/java/org/codelibs/fess/suggest/settings/AnalyzerSettings.java

         * If the analyzer settings index does not exist, it creates it with default settings and mappings.
         * It also loads analyzer names and field analyzer mappings.
         */
        public synchronized void init() {
            try {
                final IndicesExistsResponse response =
                        client.admin().indices().prepareExists(analyzerSettingsIndexName).execute().actionGet(settings.getIndicesTimeout());
    Created: Fri Apr 17 09:08:13 GMT 2026
    - Last Modified: Sun Feb 01 12:48:24 GMT 2026
    - 24.4K bytes
    - Click Count (0)
  6. src/main/java/jcifs/smb/SmbResourceLocatorImpl.java

        boolean isRootOrShare() {
            // length == 0 should not happen
            return getUNCPath().length() <= 1;
        }
    
        /**
         * @throws MalformedURLException
         *
         */
        private synchronized void canonicalizePath() {
            final char[] in = this.url.getPath().toCharArray();
            final char[] out = new char[in.length];
            final int length = in.length;
            int prefixLen = 0, state = 0;
    
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 07:14:38 GMT 2025
    - 23.6K bytes
    - Click Count (0)
  7. guava-tests/test/com/google/common/collect/MultimapsCollectionTest.java

                          multimap.put(entry.getKey(), entry.getValue());
                        }
                        return multimap;
                      }
                    })
                .named("synchronized ArrayListMultimap")
                .withFeatures(
                    MapFeature.ALLOWS_NULL_KEYS,
                    MapFeature.ALLOWS_NULL_VALUES,
                    MapFeature.ALLOWS_ANY_NULL_QUERIES,
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Sep 24 22:52:18 GMT 2025
    - 28.6K bytes
    - Click Count (0)
  8. src/main/java/org/codelibs/fess/helper/IndexingHelper.java

                        }
                    });
                }
                final CrawlingConfigHelper crawlingConfigHelper = ComponentUtil.getCrawlingConfigHelper();
                synchronized (searchEngineClient) {
                    final long deletedDocCount = deleteOldDocuments(searchEngineClient, docList);
                    if (logger.isDebugEnabled()) {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Nov 28 16:29:12 GMT 2025
    - 26.1K bytes
    - Click Count (0)
  9. compat/maven-plugin-api/src/main/java/org/apache/maven/plugin/descriptor/MojoDescriptor.java

        public org.apache.maven.api.plugin.descriptor.MojoDescriptor getMojoDescriptorV4() {
            if (mojoDescriptorV4 == null) {
                synchronized (this) {
                    if (mojoDescriptorV4 == null) {
                        mojoDescriptorV4 = org.apache.maven.api.plugin.descriptor.MojoDescriptor.newBuilder()
                                .goal(goal)
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Fri Jun 06 14:28:57 GMT 2025
    - 21.7K bytes
    - Click Count (0)
  10. okhttp/src/jvmTest/kotlin/okhttp3/internal/ws/WebSocketHttpTest.kt

              }
            }
          }
        clientListener.setNextEventDelegate(reconnectOnFailure)
        webSockets.add(client.newWebSocket(request, clientListener))
        attempts.await()
        synchronized(webSockets) {
          for (webSocket in webSockets) {
            webSocket.cancel()
          }
        }
      }
    
      @Test
      @Throws(Exception::class)
      fun compressedMessages() {
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Nov 04 19:13:52 GMT 2025
    - 35.5K bytes
    - Click Count (0)
Back to Top