Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 224 for sock (0.01 sec)

  1. guava/src/com/google/common/util/concurrent/Striped.java

         * error-prone code like:
         *
         * Striped<Lock> stripedLock = Striped.lazyWeakXXX(...)'
         * Iterable<Lock> locks = stripedLock.bulkGet(keys);
         * for (Lock lock : locks) {
         *   lock.lock();
         * }
         * operation();
         * for (Lock lock : locks) {
         *   lock.unlock();
         * }
         *
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sat Aug 09 01:14:59 UTC 2025
    - 20.6K bytes
    - Viewed (0)
  2. android/guava-tests/benchmark/com/google/common/util/concurrent/CycleDetectingLockFactoryBenchmark.java

        for (int i = 0; i < reps; i++) {
          lock.lock();
          lock.unlock();
        }
      }
    
      @Benchmark
      void orderedPlainLocks(int reps) {
        lockAndUnlockNested(plainLocks, reps);
      }
    
      @Benchmark
      void orderedCycleDetectingLocks(int reps) {
        lockAndUnlockNested(detectingLocks, reps);
      }
    
      private static void lockAndUnlockNested(Lock[] locks, int reps) {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Dec 19 18:03:30 UTC 2024
    - 2.5K bytes
    - Viewed (0)
  3. src/test/java/org/codelibs/fess/helper/WebFsIndexHelperTest.java

                assertTrue(true);
            }
        }
    
        public void test_crawl_withWebConfigOnly() {
            List<String> webConfigIds = Arrays.asList("webConfig1", "webConfig2");
    
            // Mock CrawlingConfigHelper
            CrawlingConfigHelper crawlingConfigHelper = new CrawlingConfigHelper() {
                @Override
                public List<WebConfig> getWebConfigListByIds(List<String> webConfigIdList) {
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Thu Jul 10 13:41:04 UTC 2025
    - 15.2K bytes
    - Viewed (0)
  4. src/test/java/org/codelibs/fess/mylasta/creator/PagerCreatorTest.java

        public void test_setPagerCustomizer_and_getPagerCustomizer() {
            // Create a mock customizer
            ComponentCustomizer customizer = new ComponentCustomizer() {
                @Override
                public void customize(org.lastaflute.di.core.ComponentDef componentDef) {
                    // Mock implementation
                }
            };
    
            // Set the customizer
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 13.6K bytes
    - Viewed (0)
  5. src/test/java/org/codelibs/fess/job/SuggestJobTest.java

            public void start() {
                // Mock implementation
            }
    
            // Custom join method to avoid overriding final Thread.join()
            public void waitForCompletion(long millis) {
                // Mock implementation
            }
    
            @Override
            public String getOutput() {
                return output;
            }
        }
    
        // Mock Process implementation
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 31.4K bytes
    - Viewed (0)
  6. src/test/java/org/codelibs/fess/filter/WebApiFilterTest.java

            assertTrue(true);
        }
    
        // Test doFilter when WebApiManagerFactory returns null WebApiManager
        public void test_doFilter_withNullWebApiManager() throws IOException, ServletException {
            // Setup mock objects
            HttpServletRequest request = createMockHttpServletRequest();
            HttpServletResponse response = createMockHttpServletResponse();
            AtomicBoolean chainCalled = new AtomicBoolean(false);
    
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 26.2K bytes
    - Viewed (0)
  7. android/guava-tests/test/com/google/common/util/concurrent/TestThread.java

     * test with reference to the same "lock-like object", and then their interactions with that object
     * are choreographed via the various methods on this class.
     *
     * <p>A "lock-like object" is really any object that may be used for concurrency control. If the
     * {@link #callAndAssertBlocks} method is ever called in a test, the lock-like object must have a
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 10.8K bytes
    - Viewed (0)
  8. src/test/java/org/codelibs/fess/helper/JobHelperTest.java

                // Mock implementation that doesn't require client
                entity.setLastUpdated(System.currentTimeMillis());
            }
    
            @Override
            public void update(JobLog entity) {
                // Mock implementation that doesn't require client
                entity.setLastUpdated(System.currentTimeMillis());
            }
        }
    
        // Simple mock class without complex interface requirements
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Sat Jul 19 23:49:30 UTC 2025
    - 6.2K bytes
    - Viewed (0)
  9. okhttp-testing-support/src/main/kotlin/okhttp3/RecordingEventListener.kt

      /** The timestamp of the last taken event, used to measure elapsed time between events. */
      private var lastTimestampNs: Long? = null
    
      /** Confirm that the thread does not hold a lock on `lock` during the callback. */
      fun forbidLock(lock: Any) {
        forbiddenLocks.add(lock)
      }
    
      /**
       * Removes recorded events up to (and including) an event is found whose class equals [eventClass]
       * and returns it.
       */
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Tue May 27 14:58:02 UTC 2025
    - 9.5K bytes
    - Viewed (0)
  10. android/guava/src/com/google/common/util/concurrent/Uninterruptibles.java

      }
    
      /**
       * Invokes {@code lock.}{@link Lock#tryLock(long, TimeUnit) tryLock(timeout, unit)}
       * uninterruptibly.
       *
       * @since 30.0
       */
      @J2ktIncompatible
      @GwtIncompatible // concurrency
      @SuppressWarnings("GoodTime") // should accept a java.time.Duration
      public static boolean tryLockUninterruptibly(Lock lock, long timeout, TimeUnit unit) {
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Thu Aug 07 16:05:33 UTC 2025
    - 19.8K bytes
    - Viewed (0)
Back to top