Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 60 for subDir (0.05 sec)

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

        @Override
        public <T> Future<T> submit(Callable<T> task) {
          lastMethodCalled = "submit";
          assertThat(task).isInstanceOf(WrappedCallable.class);
          return inline.submit(task);
        }
    
        @Override
        public Future<?> submit(Runnable task) {
          lastMethodCalled = "submit";
          assertThat(task).isInstanceOf(WrappedRunnable.class);
          return inline.submit(task);
        }
    
        @Override
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 9.9K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java

                },
                directExecutor());
        for (int i = 0; i < 25_000; i++) {
          serializer.submit(Callables.<Void>returning(null), directExecutor()).cancel(true);
          unused = serializer.submit(Callables.<Void>returning(null), directExecutor());
        }
        ListenableFuture<Integer> stackDepthCheck =
            serializer.submit(
                new Callable<Integer>() {
                  @Override
                  public Integer call() {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 16.7K bytes
    - Viewed (0)
  3. guava-tests/test/com/google/common/util/concurrent/ExecutionSequencerTest.java

                },
                directExecutor());
        for (int i = 0; i < 25_000; i++) {
          serializer.submit(Callables.<Void>returning(null), directExecutor()).cancel(true);
          unused = serializer.submit(Callables.<Void>returning(null), directExecutor());
        }
        ListenableFuture<Integer> stackDepthCheck =
            serializer.submit(
                new Callable<Integer>() {
                  @Override
                  public Integer call() {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 16.7K bytes
    - Viewed (0)
  4. android/guava-tests/test/com/google/common/util/concurrent/WrappingExecutorServiceTest.java

        @Override
        public <T> Future<T> submit(Callable<T> task) {
          lastMethodCalled = "submit";
          assertThat(task).isInstanceOf(WrappedCallable.class);
          return inline.submit(task);
        }
    
        @Override
        public Future<?> submit(Runnable task) {
          lastMethodCalled = "submit";
          assertThat(task).isInstanceOf(WrappedRunnable.class);
          return inline.submit(task);
        }
    
        @Override
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 9.9K bytes
    - Viewed (0)
  5. guava-tests/test/com/google/common/collect/QueuesTest.java

          Future<?> possiblyIgnoredError = threadPool.submit(new Producer(q, 20));
          @SuppressWarnings("unused") // https://errorprone.info/bugpattern/FutureReturnValueIgnored
          Future<?> possiblyIgnoredError1 = threadPool.submit(new Producer(q, 20));
          @SuppressWarnings("unused") // https://errorprone.info/bugpattern/FutureReturnValueIgnored
          Future<?> possiblyIgnoredError2 = threadPool.submit(new Producer(q, 20));
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Thu Oct 17 02:42:09 UTC 2024
    - 12.1K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java

        Thread otherThread =
            new Thread(
                new Runnable() {
                  @Override
                  public void run() {
                    try {
                      Future<?> future = executor.submit(incrementTask);
                      assertTrue(future.isDone());
                      assertEquals(1, threadLocalCount.get().intValue());
                    } catch (Throwable t) {
                      throwableFromOtherThread.set(t);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 28.1K bytes
    - Viewed (0)
  7. src/main/webapp/WEB-INF/view/index.jsp

    				<jsp:include page="searchOptions.jsp" />
    				<div>
    					<button type="button" class="btn btn-light" id="searchOptionsClearButton">
    						<la:message key="labels.search_options_clear" />
    					</button>
    					<button type="submit" class="btn btn-primary">
    						<em class="fa fa-search">
    						<la:message key="labels.search" />
    					</button>
    					<la:link href="/search/advance" styleClass="btn btn-info">
    						<em class="fa fa-cog">
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Sat Oct 26 01:07:52 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  8. guava/src/com/google/common/util/concurrent/MoreExecutors.java

      @GwtIncompatible
      public static Executor newSequentialExecutor(Executor delegate) {
        return new SequentialExecutor(delegate);
      }
    
      /**
       * Creates an {@link ExecutorService} whose {@code submit} and {@code invokeAll} methods submit
       * {@link ListenableFutureTask} instances to the given delegate executor. Those methods, as well
       * as {@code execute} and {@code invokeAny}, are implemented in terms of calls to {@code
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 44.1K bytes
    - Viewed (0)
  9. android/guava-tests/test/com/google/common/util/concurrent/WrappingScheduledExecutorServiceTest.java

        }
    
        @Override
        public <T> Future<T> submit(Callable<T> task) {
          throw new UnsupportedOperationException();
        }
    
        @Override
        public Future<?> submit(Runnable task) {
          throw new UnsupportedOperationException();
        }
    
        @Override
        public <T> Future<T> submit(Runnable task, T result) {
          throw new UnsupportedOperationException();
        }
    
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Fri Oct 18 22:10:29 UTC 2024
    - 7.6K bytes
    - Viewed (0)
  10. tensorflow/c/eager/immediate_execution_tensor_handle.cc

        value_string = "<error computing value>";
      }
      if (value_string.length() > 100) {
        // The default NumPy-style output can be distractingly long in error
        // messages.
        value_string = absl::StrCat(value_string.substr(0, 100), " [...]");
      }
      absl::Status s;
      const char* device_name = DeviceName(&s);
      if (!s.ok()) {
        device_name = "<error fetching device name>";
      }
    Registered: Tue Nov 05 12:39:12 UTC 2024
    - Last Modified: Sat Oct 12 05:24:07 UTC 2024
    - 2.1K bytes
    - Viewed (0)
Back to top