Search Options

Results per page
Sort
Preferred Languages
Advance

Results 661 - 670 of 801 for Threads (0.04 sec)

  1. guava/src/com/google/common/base/Stopwatch.java

     * #createStarted(Ticker)} to supply a fake or mock ticker. This allows you to simulate any valid
     * behavior of the stopwatch.
     *
     * <p><b>Note:</b> This class is not thread-safe.
     *
     * <p><b>Warning for Android users:</b> a stopwatch with default behavior may not continue to keep
     * time while the device is asleep. Instead, create one like this:
     *
     * {@snippet :
     * Stopwatch.createStarted(
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Wed Oct 08 18:55:33 UTC 2025
    - 9.2K bytes
    - Viewed (0)
  2. api/maven-api-core/src/main/java/org/apache/maven/api/package-info.java

     *
     * <p>The {@link org.apache.maven.api.Session} interface is the main entry point for Maven operations.
     * It maintains the state of a Maven execution and provides access to all core services and components.
     * Sessions are thread-safe and can be obtained in session-scoped components using the
     * {@link org.apache.maven.api.di.SessionScoped} annotation.</p>
     *
     * <p>Key capabilities provided through the Session include:</p>
     * <ul>
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Mon Dec 15 11:13:42 UTC 2025
    - 7.7K bytes
    - Viewed (0)
  3. src/test/java/org/codelibs/fess/suggest/index/SuggestIndexerTest.java

            assertTrue(oldWordsCount > 0);
    
            // Minimal sleep to ensure timestamp separation (reduced from 2000ms to 100ms total)
            Thread.sleep(50);
            ZonedDateTime threshold = ZonedDateTime.now();
            Thread.sleep(50);
    
            // Index new data after threshold
            document = new HashMap<>();
            document.put(field, "検索エンジン");
    Registered: Sat Dec 20 13:04:59 UTC 2025
    - Last Modified: Mon Nov 24 03:40:05 UTC 2025
    - 28.4K bytes
    - Viewed (0)
  4. fess-crawler/src/main/java/org/codelibs/fess/net/protocol/gcs/Handler.java

            /**
             * Establishes a connection to the GCS service.
             * This method creates a GCS Storage 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 {
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Thu Dec 11 08:38:29 UTC 2025
    - 9.6K bytes
    - Viewed (0)
  5. fess-crawler/src/main/java/org/codelibs/fess/net/protocol/s3/Handler.java

            }
    
            /**
             * Establishes a connection to the S3 service.
             * This method creates an AWS S3 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 {
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Thu Dec 11 07:57:44 UTC 2025
    - 9.5K bytes
    - Viewed (0)
  6. android/guava/src/com/google/common/collect/Sets.java

      }
    
      /**
       * Creates a thread-safe set backed by a hash map. The set is backed by a {@link
       * ConcurrentHashMap} instance, and thus carries the same concurrency guarantees.
       *
       * <p>Unlike {@code HashSet}, this class does NOT allow {@code null} to be used as an element. The
       * set is serializable.
       *
       * @return a new, empty thread-safe {@code Set}
       * @since 15.0
       */
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Sep 22 18:35:44 UTC 2025
    - 81.6K bytes
    - Viewed (0)
  7. src/test/java/jcifs/internal/smb1/trans/TransPeekNamedPipeResponseTest.java

            assertEquals(TransPeekNamedPipeResponse.STATUS_LISTENING, response.getStatus());
            // Middle bytes were read but not used
        }
    
        @Test
        @DisplayName("Test consecutive reads update state correctly")
        void testConsecutiveReads() {
            // First read
            byte[] buffer1 = new byte[10];
            SMBUtil.writeInt2(100, buffer1, 0);
            SMBUtil.writeInt2(0, buffer1, 2);
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Thu Aug 14 05:31:44 UTC 2025
    - 15.8K bytes
    - Viewed (0)
  8. fess-crawler/src/test/java/org/codelibs/fess/crawler/client/smb/SmbClientTest.java

            SmbClient client = new SmbClient() {
                @Override
                protected ResponseData getResponseData(final String uri, final boolean includeContent) {
                    try {
                        Thread.sleep(2000);
                    } catch (InterruptedException e) {
                        throw new CrawlingAccessException(e);
                    }
                    return null;
                }
            };
    Registered: Sat Dec 20 11:21:39 UTC 2025
    - Last Modified: Tue Sep 23 06:42:59 UTC 2025
    - 31.9K bytes
    - Viewed (0)
  9. internal/event/target/nsq.go

    	if err != nil {
    		return err
    	}
    
    	return target.producer.Publish(target.args.Topic, data)
    }
    
    // SendFromStore - reads an event from store and sends it to NSQ.
    func (target *NSQTarget) SendFromStore(key store.Key) error {
    	if err := target.init(); err != nil {
    		return err
    	}
    
    	_, err := target.isActive()
    	if err != nil {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Mar 30 00:56:02 UTC 2025
    - 7.1K bytes
    - Viewed (0)
  10. src/main/java/jcifs/smb/SmbOperationException.java

            }
            return String.format("[%s] %s: %s", errorCode.name(), errorCode.getDescription(), message);
        }
    
        private String extractOperationName() {
            StackTraceElement[] stack = Thread.currentThread().getStackTrace();
            for (StackTraceElement element : stack) {
                String className = element.getClassName();
                if (className.startsWith("jcifs.smb") && !className.contains("Exception")) {
    Registered: Sat Dec 20 13:44:44 UTC 2025
    - Last Modified: Sat Aug 30 05:58:03 UTC 2025
    - 16.5K bytes
    - Viewed (0)
Back to top