Search Options

Display Count
Sort
Preferred Language
Advanced Search

Results 451 - 460 of 659 for consumer (0.05 seconds)

  1. android/guava/src/com/google/common/util/concurrent/ThreadFactoryBuilder.java

     *
     * <p>If no backing thread factory is provided, a default backing thread factory is used as if by
     * calling {@code setThreadFactory(}{@link Executors#defaultThreadFactory()}{@code )}.
     *
     * <p><b>Java 21+ users:</b> consider using the {@code Thread.Builder} interface instead. E.g.,
     * instead of {@code new ThreadFactoryBuilder().setPriority(priority).setDaemon(false).build()}, use
     * {@code Thread.ofPlatform().priority(priority).daemon(false).factory()}.
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Dec 29 17:36:00 GMT 2025
    - 9.2K bytes
    - Click Count (0)
  2. guava-testlib/src/com/google/common/collect/testing/google/AbstractMultisetSetCountTester.java

    @SuppressWarnings("JUnit4ClassUsedInJUnit3")
    public abstract class AbstractMultisetSetCountTester<E> extends AbstractMultisetTester<E> {
      /*
       * TODO: consider adding MultisetFeatures.SUPPORTS_SET_COUNT. Currently we
       * assume that using setCount() to increase the count is permitted iff add()
       * is permitted and similarly for decrease/remove(). We assume that a
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Aug 07 16:05:33 GMT 2025
    - 13K bytes
    - Click Count (0)
  3. compat/maven-artifact/src/main/java/org/apache/maven/artifact/DefaultArtifact.java

                            } else {
                                result = -1;
                            }
                        }
                        if (result == 0) {
                            // We don't consider the version range in the comparison, just the resolved version
                            result = new DefaultArtifactVersion(version)
                                    .compareTo(new DefaultArtifactVersion(a.getVersion()));
    Created: Sun Apr 05 03:35:12 GMT 2026
    - Last Modified: Wed Jul 23 17:27:08 GMT 2025
    - 14.6K bytes
    - Click Count (0)
  4. guava-tests/test/com/google/common/io/ByteSourceTest.java

            new ByteProcessor<@Nullable Void>() {
              boolean firstCall = true;
    
              @Override
              public boolean processBytes(byte[] buf, int off, int len) throws IOException {
                assertTrue("consume() called twice", firstCall);
                firstCall = false;
                return false;
              }
    
              @Override
              public @Nullable Void getResult() {
                return null;
              }
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Thu Mar 19 18:53:45 GMT 2026
    - 15.6K bytes
    - Click Count (0)
  5. guava/src/com/google/common/base/internal/Finalizer.java

    import org.jspecify.annotations.Nullable;
    
    /**
     * Thread that finalizes referents. All references should implement {@code
     * com.google.common.base.FinalizableReference}.
     *
     * <p>While this class is public, we consider it to be *internal* and not part of our published API.
     * It is public so we can access it reflectively across class loaders in secure environments.
     *
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Wed Mar 11 03:19:29 GMT 2026
    - 9.6K bytes
    - Click Count (0)
  6. guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java

          service.shutdown();
        }
        assertThat(holder.count).isEqualTo(ITERATION_COUNT);
        for (int length : completeLengthChecks) {
          // Verify that at max depth, less than one stack frame per submitted task was consumed
          assertThat(length - baseStackDepth).isLessThan(DIRECT_EXECUTIONS_PER_THREAD / 2);
        }
      }
    
      @SuppressWarnings("ObjectToString") // Intended behavior
      public void testToString() {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Mon Mar 16 22:45:21 GMT 2026
    - 13.6K bytes
    - Click Count (0)
  7. android/guava/src/com/google/common/util/concurrent/TimeoutFuture.java

        result.timer = scheduledExecutor.schedule(fire, time, unit);
        delegate.addListener(fire, directExecutor());
        return result;
      }
    
      /*
       * Memory visibility of these fields. There are two cases to consider.
       *
       * 1. visibility of the writes to these fields to Fire.run:
       *
       * The initial write to delegateRef is made definitely visible via the semantics of
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 8K bytes
    - Click Count (0)
  8. android/guava/src/com/google/common/escape/ArrayBasedCharEscaper.java

     * single character '{@code \}{@code u1000}' will require approximately 16K of memory. If you need
     * to create multiple escaper instances that have the same character replacement mapping consider
     * using {@link ArrayBasedEscaperMap}.
     *
     * @author Sven Mawson
     * @author David Beaumont
     * @since 15.0
     */
    @GwtCompatible
    public abstract class ArrayBasedCharEscaper extends CharEscaper {
    Created: Fri Apr 03 12:43:13 GMT 2026
    - Last Modified: Sun Dec 22 03:38:46 GMT 2024
    - 6.2K bytes
    - Click Count (0)
  9. CODE_OF_CONDUCT.md

    Violations of the Code of Conduct can occur in any setting, even those unrelated to the project. We will only consider complaints about conduct that has occurred within one year of the report.
    
    
    ## Enforcement
    
    Created: Tue Apr 07 12:39:13 GMT 2026
    - Last Modified: Fri Feb 05 18:43:16 GMT 2021
    - 5.2K bytes
    - Click Count (0)
  10. src/test/java/jcifs/smb/DirFileEntryEnumIteratorBaseTest.java

            // Act
            assertTrue(it.hasNext());
            assertEquals("one", it.next().getName()); // consume initial
            // Next call should handle CIFSException and close iterator
            assertFalse(it.hasNext()); // After error, hasNext should return false
    
            // Assert
            verify(tree, times(1)).release();
    Created: Sun Apr 05 00:10:12 GMT 2026
    - Last Modified: Thu Aug 14 05:31:44 GMT 2025
    - 14.5K bytes
    - Click Count (0)
Back to Top