Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 627 for Runnables (0.31 sec)

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

    /**
     * Static utility methods pertaining to the {@link Runnable} interface.
     *
     * @since 16.0
     */
    @GwtCompatible
    @ElementTypesAreNonnullByDefault
    public final class Runnables {
    
      private static final Runnable EMPTY_RUNNABLE =
          new Runnable() {
            @Override
            public void run() {}
          };
    
      /** Returns a {@link Runnable} instance that does nothing when run. */
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri May 12 18:32:03 UTC 2023
    - 1.1K bytes
    - Viewed (0)
  2. guava/src/com/google/common/util/concurrent/Runnables.java

    /**
     * Static utility methods pertaining to the {@link Runnable} interface.
     *
     * @since 16.0
     */
    @GwtCompatible
    @ElementTypesAreNonnullByDefault
    public final class Runnables {
    
      private static final Runnable EMPTY_RUNNABLE =
          new Runnable() {
            @Override
            public void run() {}
          };
    
      /** Returns a {@link Runnable} instance that does nothing when run. */
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri May 12 18:32:03 UTC 2023
    - 1.1K bytes
    - Viewed (0)
  3. guava/src/com/google/common/util/concurrent/ExecutionList.java

          if (!executed) {
            runnables = new RunnableExecutorPair(runnable, executor, runnables);
            return;
          }
        }
        // Execute the runnable immediately. Because of scheduling this may end up getting called before
        // some of the previously added runnables, but we're OK with that. If we want to change the
        // contract to guarantee ordering among runnables we'd have to modify the logic here to allow
        // it.
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Mon Apr 22 21:17:24 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/RunnablesTest.java

    import com.google.common.annotations.GwtCompatible;
    import junit.framework.TestCase;
    
    /**
     * Unit tests for {@link Runnables}.
     *
     * @author Olivier Pernet
     */
    @GwtCompatible
    public class RunnablesTest extends TestCase {
      public void testDoNothingRunnableIsSingleton() {
        assertSame(Runnables.doNothing(), Runnables.doNothing());
      }
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Fri Apr 21 02:27:51 UTC 2017
    - 986 bytes
    - Viewed (0)
  5. android/guava/src/com/google/common/util/concurrent/ExecutionList.java

          if (!executed) {
            runnables = new RunnableExecutorPair(runnable, executor, runnables);
            return;
          }
        }
        // Execute the runnable immediately. Because of scheduling this may end up getting called before
        // some of the previously added runnables, but we're OK with that. If we want to change the
        // contract to guarantee ordering among runnables we'd have to modify the logic here to allow
        // it.
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Mon Apr 22 21:17:24 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/util/concurrent/RunnablesTest.java

    import com.google.common.annotations.GwtCompatible;
    import junit.framework.TestCase;
    
    /**
     * Unit tests for {@link Runnables}.
     *
     * @author Olivier Pernet
     */
    @GwtCompatible
    public class RunnablesTest extends TestCase {
      public void testDoNothingRunnableIsSingleton() {
        assertSame(Runnables.doNothing(), Runnables.doNothing());
      }
    Registered: Wed Jun 12 16:38:11 UTC 2024
    - Last Modified: Thu Sep 15 13:47:32 UTC 2016
    - 986 bytes
    - Viewed (0)
  7. src/test/java/jcifs/tests/ConcurrencyTest.java

                ExclusiveLockSecond s = new ExclusiveLockSecond(f, exclFile);
    
                List<MultiTestCase> runnables = new ArrayList<>();
                runnables.add(f);
                runnables.add(s);
                runMultiTestCase(runnables, 10);
            }
        }
    
    
        @Test
        public void testDeleteLocked () throws IOException {
            String fname = makeRandomName();
    Registered: Wed Jun 12 15:45:55 UTC 2024
    - Last Modified: Sun Nov 14 17:40:50 UTC 2021
    - 17.6K bytes
    - Viewed (0)
  8. platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/internal/ExclusiveCacheAccessingWorker.java

                List<Runnable> runnables = new ArrayList<Runnable>();
                workQueue.drainTo(runnables);
                for (Runnable runnable : runnables) {
                    if (runnable instanceof FlushOperationsCommand) {
                        FlushOperationsCommand flushOperationsCommand = (FlushOperationsCommand) runnable;
                        flushOperationsCommand.completed();
                    }
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Tue Apr 16 15:49:50 UTC 2024
    - 8.8K bytes
    - Viewed (0)
  9. platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/internal/FixedExclusiveModeCrossProcessCacheAccess.java

                    fileLock.close();
                } finally {
                    fileLock = null;
                }
            }
        }
    
        @Override
        public Runnable acquireFileLock() {
            return Runnables.doNothing();
        }
    
        @Override
        public <T> T withFileLock(Supplier<T> factory) {
            return factory.get();
        }
    
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Wed May 01 12:21:15 UTC 2024
    - 3.6K bytes
    - Viewed (0)
  10. platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/internal/InMemoryDecoratedCache.java

            } else {
                return Cast.uncheckedCast(value);
            }
        }
    
        @Override
        public V get(final K key, final Function<? super K, ? extends V> producer, final Runnable completion) {
            final AtomicReference<Runnable> completionRef = new AtomicReference<>(completion);
            Object value;
            try {
                value = inMemoryCache.getIfPresent(key);
                final boolean wasNull = value == NULL;
    Registered: Wed Jun 12 18:38:38 UTC 2024
    - Last Modified: Fri Sep 22 09:08:47 UTC 2023
    - 5.3K bytes
    - Viewed (0)
Back to top