Search Options

Results per page
Sort
Preferred Languages
Advance

Results 481 - 490 of 638 for threadId (0.07 sec)

  1. api/maven-api-core/src/main/java/org/apache/maven/api/SessionData.java

     * abused as a cache (i.e. for storing values that can be re-calculated) to avoid memory exhaustion.
     * <p>
     * <strong>Note:</strong> Actual implementations must be thread-safe.
     *
     * @see Session#getData()
     * @since 4.0.0
     */
    @Experimental
    @ThreadSafe
    @Provider
    public interface SessionData {
    
        /**
         * Associates the specified session data with the given key.
    Registered: Sun Sep 07 03:35:12 UTC 2025
    - Last Modified: Wed Feb 28 23:31:09 UTC 2024
    - 4.7K bytes
    - Viewed (0)
  2. src/main/java/jcifs/SmbResourceException.java

            case BUFFER:
                return "Reduce buffer usage or increase buffer pool size";
            case THREAD_POOL:
                return "Reduce concurrent operations or increase thread pool size";
            default:
                return "Check resource availability and retry";
            }
        }
    
        /**
         * Static factory for file handle exhaustion
         */
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 5.6K bytes
    - Viewed (0)
  3. android/guava-testlib/test/com/google/common/testing/FakeTickerTest.java

            new Callable<@Nullable Void>() {
              @Override
              public @Nullable Void call() throws Exception {
                // adds two nanoseconds to the ticker
                ticker.advance(1L);
                Thread.sleep(10);
                ticker.advance(1L);
                return null;
              }
            });
    
        assertEquals(numberOfThreads * 2, ticker.read());
      }
    
      @GwtIncompatible // concurrency
    
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 6.5K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/collect/MapMakerInternalMap.java

         * cleaning up from the read thread.
         */
        void postReadCleanup() {
          if ((readCount.incrementAndGet() & DRAIN_THRESHOLD) == 0) {
            runCleanup();
          }
        }
    
        /**
         * Performs routine cleanup prior to executing a write. This should be called every time a write
         * thread acquires the segment lock, immediately after acquiring the lock.
         */
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Aug 11 19:31:30 UTC 2025
    - 90K bytes
    - Viewed (0)
  5. docs/smb3-features/02-persistent-handles-design.md

            }
            
            return CompletableFuture.supplyAsync(() -> {
                try {
                    // Wait before retry (except first attempt)
                    if (attempt > 0) {
                        Thread.sleep(retryDelay * attempt);
                    }
                    
                    // Create reconnect context
                    DurableHandleReconnect reconnectCtx = 
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 02:53:50 UTC 2025
    - 31.6K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/app/service/FailureUrlService.java

            failureUrl.setErrorName(errorName);
            failureUrl.setErrorLog(getStackTrace(e));
            failureUrl.setLastAccessTime(ComponentUtil.getSystemHelper().getCurrentTimeAsLong());
            failureUrl.setThreadName(Thread.currentThread().getName());
    
            bhv.insertOrUpdate(failureUrl, op -> {
                op.setRefreshPolicy(Constants.TRUE);
            });
            return failureUrl;
        }
    
        /**
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 9.2K bytes
    - Viewed (0)
  7. fess-crawler/src/main/java/org/codelibs/fess/crawler/service/impl/UrlQueueServiceImpl.java

     *   <li>Checking if a URL has already been visited.</li>
     *   <li>Generating URL queues from a previous session's access results.</li>
     * </ul>
     *
     * <p>
     * The class uses synchronization to ensure thread safety when accessing and modifying the URL queue.
     * It also checks for duplicate URLs before adding them to the queue,
     * both within the queue itself and against previously accessed URLs stored in the {@link MemoryDataHelper}.
    Registered: Sun Sep 21 03:50:09 UTC 2025
    - Last Modified: Sun Jul 06 02:13:03 UTC 2025
    - 9.3K bytes
    - Viewed (0)
  8. src/main/java/org/codelibs/fess/app/pager/FailureUrlPager.java

        private int pageSize;
    
        /** Current page number. */
        private int currentPageNumber;
    
        /** ID of the failure URL record. */
        public String id;
    
        /** Name of the thread that encountered the failure. */
        public String threadName;
    
        /** Number of errors encountered for this URL. */
        public String errorCount;
    
        /** Last time this URL was accessed. */
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 17 08:28:31 UTC 2025
    - 7K bytes
    - Viewed (0)
  9. src/main/java/jcifs/smb/SmbCopyUtil.java

                    }
                }
            } catch (final MalformedURLException mue) {
                throw new SmbException(src.getURL().toString(), mue);
            }
        }
    
    }
    
    class WriterThread extends Thread {
    
        private byte[] b;
        private int n;
        private boolean ready;
        private SmbFileOutputStream out;
    
        private SmbException e = null;
    
        WriterThread() {
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 16 01:32:48 UTC 2025
    - 16.6K bytes
    - Viewed (0)
  10. src/test/java/jcifs/smb/SmbOperationExceptionTest.java

        void testElapsedTime() throws InterruptedException {
            // Given
            exception = new SmbOperationException(SmbOperationException.ErrorCode.BUSY, "Server busy");
    
            // When
            Thread.sleep(100);
    
            // Then
            assertTrue(exception.getElapsedTime() >= 100);
            assertTrue(exception.getElapsedTime() < 200);
        }
    
        @Test
    Registered: Sun Sep 07 00:10:21 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 16.1K bytes
    - Viewed (0)
Back to top