Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 1 - 5 of 5 for isParallel (0.18 seconds)

  1. guava/src/com/google/common/collect/Streams.java

        boolean isParallel = false;
        int characteristics = Spliterator.ORDERED | Spliterator.SIZED | Spliterator.NONNULL;
        long estimatedSize = 0L;
        ImmutableList.Builder<Spliterator<? extends T>> splitrsBuilder =
            new ImmutableList.Builder<>(streams.length);
        for (Stream<? extends T> stream : streams) {
          isParallel |= stream.isParallel();
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Feb 23 19:19:10 GMT 2026
    - 36.4K bytes
    - Click Count (0)
  2. android/guava/src/com/google/common/collect/Streams.java

        boolean isParallel = false;
        int characteristics = Spliterator.ORDERED | Spliterator.SIZED | Spliterator.NONNULL;
        long estimatedSize = 0L;
        ImmutableList.Builder<Spliterator<? extends T>> splitrsBuilder =
            new ImmutableList.Builder<>(streams.length);
        for (Stream<? extends T> stream : streams) {
          isParallel |= stream.isParallel();
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Feb 23 19:19:10 GMT 2026
    - 36.8K bytes
    - Click Count (0)
  3. okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt

      private val tasksExecutor = Executors.newCachedThreadPool(threadFactory("TaskFaker"))
    
      /**
       * True if this task faker has ever had multiple tasks scheduled to run concurrently. Guarded by
       * `this`.
       */
      var isParallel = false
    
      /** Number of calls to [TaskRunner.Backend.execute]. Guarded by `this`. */
      var executeCallCount = 0
    
      /** Guarded by [taskRunner]. */
      var nanoTime = 0L
        private set
    
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Wed May 28 23:28:25 GMT 2025
    - 11.9K bytes
    - Click Count (0)
  4. impl/maven-core/src/main/java/org/apache/maven/execution/MavenSession.java

        public Date getStartTime() {
            return request.getStartTime();
        }
    
        public Instant getStartInstant() {
            return request.getStartInstant();
        }
    
        public boolean isParallel() {
            return parallel;
        }
    
        public void setParallel(boolean parallel) {
            this.parallel = parallel;
        }
    
        public RepositorySystemSession getRepositorySession() {
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Fri Jan 24 17:29:44 GMT 2025
    - 16.7K bytes
    - Click Count (0)
  5. okhttp/src/jvmTest/kotlin/okhttp3/internal/concurrent/TaskRunnerTest.kt

          log += "one:run@${taskFaker.nanoTime} parallel=${taskFaker.isParallel}"
        }
    
        redQueue.execute("task two", 100.µs) {
          log += "two:run@${taskFaker.nanoTime} parallel=${taskFaker.isParallel}"
        }
    
        redQueue.execute("task three", 100.µs) {
          log += "three:run@${taskFaker.nanoTime} parallel=${taskFaker.isParallel}"
        }
    
        taskFaker.advanceUntil(0.µs)
        assertThat(log).isEmpty()
    Created: Fri Apr 03 11:42:14 GMT 2026
    - Last Modified: Tue Feb 03 22:17:59 GMT 2026
    - 23K bytes
    - Click Count (0)
Back to Top