Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for ran (0.02 sec)

  1. guava-tests/test/com/google/common/util/concurrent/WrappingExecutorServiceTest.java

    /**
     * Test for {@link WrappingExecutorService}
     *
     * @author Chris Nokleberg
     */
    @NullUnmarked
    public class WrappingExecutorServiceTest extends TestCase {
      private static final String RESULT_VALUE = "ran";
    
      // Uninteresting delegations
      public void testDelegations() throws InterruptedException {
        MockExecutor mock = new MockExecutor();
        TestExecutor testExecutor = new TestExecutor(mock);
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Mon Jul 14 14:44:08 UTC 2025
    - 9.9K bytes
    - Viewed (0)
  2. src/bufio/scan_test.go

    				break
    			}
    			runeCount++
    			got, _ := utf8.DecodeRune(s.Bytes())
    			if got != expect {
    				t.Errorf("#%d: %d: expected %q got %q", n, i, expect, got)
    			}
    		}
    		if s.Scan() {
    			t.Errorf("#%d: scan ran too long, got %q", n, s.Text())
    		}
    		testRuneCount := utf8.RuneCountInString(test)
    		if runeCount != testRuneCount {
    			t.Errorf("#%d: termination expected at %d; got %d", n, testRuneCount, runeCount)
    		}
    		err := s.Err()
    Registered: Tue Sep 09 11:13:09 UTC 2025
    - Last Modified: Fri Sep 22 16:22:42 UTC 2023
    - 14.3K bytes
    - Viewed (0)
  3. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/concurrent/TaskRunner.kt

                currentThread.name = task.name
                val delayNanos =
                  logger.logElapsed(task, task.queue!!) {
                    task.runOnce()
                  }
    
                // A task ran successfully. Update the execution state and take the next task.
                task = withLock {
                  afterRun(task, delayNanos, true)
                  awaitTaskToRun()
                } ?: return
              }
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Sat Aug 30 11:30:11 UTC 2025
    - 10.4K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/util/concurrent/SequentialExecutor.java

                    return;
                  } else {
                    // Increment the run counter to avoid the ABA problem of a submitter marking the
                    // thread as QUEUED after it already ran and exhausted the queue before returning
                    // from execute().
                    workerRunCount++;
                    workerRunningState = RUNNING;
                    hasSetRunning = true;
                  }
    Registered: Fri Sep 05 12:43:10 UTC 2025
    - Last Modified: Sun Dec 22 03:38:46 UTC 2024
    - 10.6K bytes
    - Viewed (0)
  5. okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/-UtilJvm.kt

        val skipBuffer = Buffer()
        while (read(skipBuffer, 8192) != -1L) {
          skipBuffer.clear()
        }
        true // Success! The source has been exhausted.
      } catch (_: InterruptedIOException) {
        false // We ran out of time before exhausting the source.
      } finally {
        if (originalDurationNs == Long.MAX_VALUE) {
          timeout().clearDeadline()
        } else {
          timeout().deadlineNanoTime(nowNs + originalDurationNs)
        }
    Registered: Fri Sep 05 11:42:10 UTC 2025
    - Last Modified: Thu Jul 31 04:18:40 UTC 2025
    - 10.2K bytes
    - Viewed (1)
  6. src/test/java/org/codelibs/fess/exec/CrawlerTest.java

            options.webConfigIds = "web1";
            options.dataConfigIds = "data1";
    
            int result = crawler.doCrawl(options);
            assertEquals(Constants.EXIT_OK, result);
    
            // Verify both crawlers ran
            assertEquals(4, executionOrder.size());
            assertTrue(executionOrder.contains("web-start"));
            assertTrue(executionOrder.contains("web-end"));
            assertTrue(executionOrder.contains("data-start"));
    Registered: Thu Sep 04 12:52:25 UTC 2025
    - Last Modified: Tue Aug 19 14:09:36 UTC 2025
    - 30.5K bytes
    - Viewed (0)
  7. cmd/object-api-errors.go

    func (e SignatureDoesNotMatch) Error() string {
    	return "The request signature we calculated does not match the signature you provided. Check your key and signing method."
    }
    
    // StorageFull storage ran out of space.
    type StorageFull struct{}
    
    func (e StorageFull) Error() string {
    	return "Storage reached its minimum free drive threshold."
    }
    
    // SlowDown  too many file descriptors open or backend busy .
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 09 02:05:14 UTC 2024
    - 22.1K bytes
    - Viewed (0)
Back to top