Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 241 - 250 of 344 for synchronized (0.06 seconds)

  1. src/main/java/org/codelibs/fess/chat/ChatSessionManager.java

                }
            }
        }
    
        /**
         * Enforces the maximum session cache size.
         */
        protected void enforceMaxSize() {
            final int maxSize = getMaxSessionSize();
            synchronized (sessionCache) {
                if (sessionCache.size() <= maxSize) {
                    return;
                }
    
                final int toRemove = sessionCache.size() - maxSize;
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Sat Mar 07 13:27:59 GMT 2026
    - 13.7K bytes
    - Click Count (0)
  2. compat/maven-plugin-api/src/main/java/org/apache/maven/plugin/descriptor/PluginDescriptor.java

        public org.apache.maven.api.plugin.descriptor.PluginDescriptor getPluginDescriptorV4() {
            if (pluginDescriptorV4 == null) {
                synchronized (this) {
                    if (pluginDescriptorV4 == null) {
                        pluginDescriptorV4 = org.apache.maven.api.plugin.descriptor.PluginDescriptor.newBuilder()
                                .namespaceUri(null)
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Fri Jun 06 14:28:57 GMT 2025
    - 16.2K bytes
    - Click Count (0)
  3. guava/src/com/google/common/collect/StandardTable.java

     * since an iteration across all row keys occurs.
     *
     * <p>Note that this implementation is not synchronized. If multiple threads access this table
     * concurrently and one of the threads modifies the table, it must be synchronized externally.
     *
     * @author Jared Levy
     */
    @GwtCompatible
    class StandardTable<R, C, V> extends AbstractTable<R, C, V> implements Serializable {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sun Mar 08 16:16:42 GMT 2026
    - 30.4K bytes
    - Click Count (0)
  4. src/main/java/jcifs/http/NtlmHttpFilter.java

                    resp.setContentLength(0);
                    resp.flushBuffer();
                    return null;
                }
            }
    
            return ntlm;
        }
    
        private synchronized NtlmChallenge getChallengeForDomain(final String domain) throws UnknownHostException, ServletException {
            if (domain == null) {
                throw new ServletException("A domain was not specified");
            }
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 30 05:58:03 GMT 2025
    - 15.3K bytes
    - Click Count (0)
  5. compat/maven-compat/src/main/java/org/apache/maven/artifact/repository/metadata/DefaultRepositoryMetadataManager.java

                                        + now
                                        + ", lastUpdated = " + lastUpdated + "). Please verify that the clocks of all"
                                        + " deploying machines are reasonably synchronized.");
                        versioning.setLastUpdated(now);
                        changed = true;
                    }
                }
            }
    
            if (changed) {
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Fri Jun 06 14:28:57 GMT 2025
    - 18.9K bytes
    - Click Count (0)
  6. impl/maven-cli/src/main/java/org/apache/maven/cling/event/ExecutionEventLogger.java

                if (totalProjects <= 1) {
                    infoMain(building);
                } else {
                    // display progress [i/n]
                    int number;
                    synchronized (this) {
                        number = ++currentVisitedProjectCount;
                    }
                    String progress = " [" + number + '/' + totalProjects + ']';
    
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Fri Dec 13 15:40:45 GMT 2024
    - 17.5K bytes
    - Click Count (0)
  7. fess-crawler-opensearch/src/main/java/org/codelibs/fess/crawler/service/impl/OpenSearchUrlQueueService.java

            final Queue<OpenSearchUrlQueue> crawlingQueue = queueHolder.crawlingQueue;
    
            OpenSearchUrlQueue urlQueue = waitingQueue.poll();
            if (urlQueue == null) {
                synchronized (queueHolder) {
                    urlQueue = waitingQueue.poll();
                    if (urlQueue == null) {
                        final List<OpenSearchUrlQueue> urlQueueList = fetchUrlQueueList(sessionId);
    Created: Sun Apr 12 03:50:13 GMT 2026
    - Last Modified: Thu Nov 20 08:40:57 GMT 2025
    - 16.9K bytes
    - Click Count (1)
  8. src/main/java/jcifs/smb/SmbFileInputStream.java

            try (SmbFileHandleImpl fh = ensureOpen()) {}
        }
    
        /**
         * @param file
         * @param openFlags
         * @return
         * @throws SmbException
         */
        synchronized SmbFileHandleImpl ensureOpen() throws CIFSException {
            if (this.handle == null || !this.handle.isValid()) {
                // one extra acquire to keep this open till the stream is released
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Sat Aug 30 05:58:03 GMT 2025
    - 15.6K bytes
    - Click Count (0)
  9. android/guava/src/com/google/common/io/ByteStreams.java

        public int available() throws IOException {
          return (int) min(in.available(), left);
        }
    
        // it's okay to mark even if mark isn't supported, as reset won't work
        @Override
        public synchronized void mark(int readLimit) {
          in.mark(readLimit);
          mark = left;
        }
    
        @Override
        public int read() throws IOException {
          if (left == 0) {
            return -1;
          }
    
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 23 21:06:42 GMT 2026
    - 31.1K bytes
    - Click Count (0)
  10. src/main/java/org/codelibs/fess/helper/SuggestHelper.java

        public void deleteBadWord(final String badWord) {
            suggester.indexer().deleteBadWord(badWord);
            refresh();
        }
    
        /**
         * Refreshes the suggest index.
         */
        public synchronized void refresh() {
            suggester.refresh();
            if (popularWordHelper != null) {
                popularWordHelper.clearCache();
            }
        }
    
        /**
    Created: Tue Mar 31 13:07:34 GMT 2026
    - Last Modified: Fri Nov 28 16:29:12 GMT 2025
    - 22.3K bytes
    - Click Count (0)
Back to Top