Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 201 - 210 of 327 for Synchronized (0.09 seconds)

  1. src/main/java/org/codelibs/fess/exec/ThumbnailGenerator.java

                }
                destroyContainer();
            }
    
            System.exit(exitCode);
        }
    
        private static void destroyContainer() {
            TimeoutManager.getInstance().stop();
            synchronized (SingletonLaContainerFactory.class) {
                SingletonLaContainerFactory.destroy();
            }
        }
    
        private static int process(final Options options) {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Thu Mar 26 02:24:08 GMT 2026
    - 10.4K bytes
    - Click Count (0)
  2. src/main/java/org/codelibs/fess/opensearch/config/exentity/WebConfig.java

                if (pattern.matcher(input).matches()) {
                    return Constants.FALSE;
                }
            }
    
            return Constants.TRUE;
        }
    
        protected synchronized void initDocUrlPattern() {
    
            final SystemHelper systemHelper = ComponentUtil.getSystemHelper();
            if (includedDocUrlPatterns == null) {
                if (StringUtil.isNotBlank(getIncludedDocUrls())) {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Jan 10 01:38:30 GMT 2026
    - 10.3K bytes
    - Click Count (0)
  3. guava-tests/test/com/google/common/collect/ImmutableSortedMultisetTest.java

            toArrayCalled = true;
            return super.toArray(a);
          }
        }
    
        // Test that toArray() is used to make a defensive copy in copyOf(), so concurrently modified
        // synchronized collections can be safely copied.
        TestArrayList<String> toCopy = new TestArrayList<>();
        ImmutableSortedMultiset<String> unused =
            ImmutableSortedMultiset.copyOf(Ordering.natural(), toCopy);
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Fri Mar 13 13:01:07 GMT 2026
    - 22.8K bytes
    - Click Count (0)
  4. src/test/java/org/codelibs/fess/rank/fusion/RankFusionProcessorConcurrencyTest.java

                                List<Map<String, Object>> results =
                                        processor.search("*", new TestSearchRequestParams(0, 10, 0), OptionalThing.empty());
                                synchronized (allResults) {
                                    allResults.add(results);
                                }
                            } catch (InterruptedException e) {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sun Jan 11 08:43:05 GMT 2026
    - 13.5K bytes
    - Click Count (0)
  5. src/main/java/org/codelibs/fess/ds/DataStoreFactory.java

         * every 60 seconds to balance performance with up-to-date plugin discovery.
         *
         * @return array of data store names sorted alphabetically, never null
         */
        public synchronized String[] getDataStoreNames() {
            final long now = ComponentUtil.getSystemHelper().getCurrentTimeAsLong();
            if (now - lastLoadedTime > 60000L) {
                final List<String> nameList = loadDataStoreNameList();
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Nov 28 16:29:12 GMT 2025
    - 9K bytes
    - Click Count (0)
  6. src/main/java/org/codelibs/fess/opensearch/config/exentity/FileConfig.java

                if (pattern.matcher(input).matches()) {
                    return Constants.FALSE;
                }
            }
    
            return Constants.TRUE;
    
        }
    
        protected synchronized void initDocPathPattern() {
            final SystemHelper systemHelper = ComponentUtil.getSystemHelper();
    
            if (includedDocPathPatterns == null) {
                if (StringUtil.isNotBlank(getIncludedDocPaths())) {
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Mon Nov 24 02:07:40 GMT 2025
    - 11.1K bytes
    - Click Count (0)
  7. android/guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java

      }
    
      private static class TestApplication extends Application {
        private final List<Thread> hooks = new ArrayList<>();
    
        @Override
        synchronized void addShutdownHook(Thread hook) {
          hooks.add(hook);
        }
    
        synchronized void shutdown() throws InterruptedException {
          for (Thread hook : hooks) {
            hook.start();
          }
          for (Thread hook : hooks) {
            hook.join();
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 26.1K bytes
    - Click Count (0)
  8. docs/smb3-features/01-smb3-lease-design.md

                this.epoch = 1;
                this.breaking = false;
            }
            
            public synchronized void updateState(int newState) {
                this.leaseState = newState;
                this.lastAccessTime = System.currentTimeMillis();
            }
            
            public synchronized void incrementEpoch() {
                this.epoch++;
            }
            
            public boolean hasReadCache() {
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 16 02:53:50 GMT 2025
    - 22K bytes
    - Click Count (0)
  9. src/test/java/jcifs/smb1/smb1/DfsTest.java

                    throws SmbAuthException {
                if (disabled)
                    return null;
                return super.getReferral(trans, domain, root, path, auth);
            }
    
            @Override
            public synchronized DfsReferral resolve(String domain, String root, String path, NtlmPasswordAuthentication auth)
                    throws SmbAuthException {
                if (disabled || root.equals("IPC$")) {
                    return null;
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 9.6K bytes
    - Click Count (0)
  10. mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt

      /** The number of bytes of the POST body to keep in memory to the given limit. */
      public var bodyLimit: Long = Long.MAX_VALUE
    
      public var serverSocketFactory: ServerSocketFactory?
        @Synchronized get() = serverSocketFactory_
    
        @Synchronized set(value) {
          check(socketAddress_ == null) { "serverSocketFactory must not be set after start()" }
          serverSocketFactory_ = value
        }
    
      /**
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Jan 27 09:00:39 GMT 2026
    - 40.3K bytes
    - Click Count (0)
Back to Top