- Sort Score
- Result 10 results
- Languages All
Results 2291 - 2300 of 2,475 for created (0.05 sec)
-
guava-tests/test/com/google/common/util/concurrent/AbstractExecutionThreadServiceTest.java
WaitOnRunService service = new WaitOnRunService(); service.startAsync().awaitRunning(); enterRun.await(); service.stopAsync().awaitTerminated(); } public void testTimeout() { // Create a service whose executor will never run its commands Service service = new AbstractExecutionThreadService() { @Override protected void run() throws Exception {} @Override
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 22:10:29 UTC 2024 - 12.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/SequentialExecutorTest.java
} } public void testRejectedExecutionThrownWithMultipleCalls() throws Exception { final CountDownLatch latch = new CountDownLatch(1); final SettableFuture<?> future = SettableFuture.create(); final Executor delegate = new Executor() { @Override public void execute(Runnable task) { if (future.set(null)) { awaitUninterruptibly(latch);
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 22:10:29 UTC 2024 - 11.4K bytes - Viewed (0) -
guava/src/com/google/common/collect/RegularImmutableBiMap.java
checkNoConflictInValueBucket(value, entry, nextInValueBucket); } catch (BucketOverflowException e) { return JdkBackedImmutableBiMap.create(n, entryArray); } ImmutableMapEntry<K, V> newEntry = (nextInValueBucket == null && nextInKeyBucket == null) ? RegularImmutableMap.makeImmutable(entry, key, value)
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Sat Oct 19 00:05:46 UTC 2024 - 11.3K bytes - Viewed (0) -
tensorflow/c/c_api_experimental_test.cc
TFE_Op* op, const std::vector<absl::optional<std::vector<int64_t>>>& input_shapes_vec, const std::vector<TF_Tensor*>& input_tensors, const absl::optional<std::vector<int64_t>>& expected_shape) { // Create input_shapes. TF_ShapeAndTypeList* input_shapes = TF_NewShapeAndTypeList(input_shapes_vec.size()); for (size_t i = 0; i < input_shapes_vec.size(); ++i) { const auto& input_shape = input_shapes_vec[i];
Registered: Tue Nov 05 12:39:12 UTC 2024 - Last Modified: Tue Jan 17 22:27:52 UTC 2023 - 13.1K bytes - Viewed (0) -
istioctl/pkg/metrics/metrics.go
log.Debugf("metrics command invoked for workload(s): %v", args) client, err := ctx.CLIClientWithRevision(metricsOpts.Revision) if err != nil { return fmt.Errorf("failed to create k8s client: %v", err) } pl, err := client.PodsForSelector(context.TODO(), ctx.IstioNamespace(), "app.kubernetes.io/name=prometheus") if err != nil { return fmt.Errorf("not able to locate Prometheus pod: %v", err)
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Sat Apr 13 05:23:38 UTC 2024 - 8.4K bytes - Viewed (0) -
compat/maven-compat/src/main/java/org/apache/maven/repository/metadata/DefaultGraphConflictResolver.java
res.addEdge(sourceV, newV, edge); } } // System.err.println("Original graph("+graph.getVertices().size()+"):\n"+graph.toString()); // System.err.println("Cleaned("+requestedScope+") graph("+res.getVertices().size()+"):\n"+res.toString()); // System.err.println("Linked("+requestedScope+") // subgraph("+linkedRes.getVertices().size()+"):\n"+linkedRes.toString());
Registered: Sun Nov 03 03:35:11 UTC 2024 - Last Modified: Fri Oct 25 12:31:46 UTC 2024 - 8.2K bytes - Viewed (0) -
internal/ioutil/ioutil.go
l = s.skipCount } n, err := s.Reader.Read(tmp[:l]) if err != nil { return 0, err } s.skipCount -= int64(n) } } return s.Reader.Read(p) } // NewSkipReader - creates a SkipReader func NewSkipReader(r io.Reader, n int64) io.Reader { return &SkipReader{r, n} } // writerOnly hides an io.Writer value's optional ReadFrom method // from io.Copy. type writerOnly struct {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jul 26 12:55:01 UTC 2024 - 10.9K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/graph/TraverserTest.java
} private static SuccessorsFunction<Character> createUndirectedGraph(String... edges) { return createGraph(/* directed= */ false, edges); } /** * Creates a graph from a list of node pairs (encoded as strings, e.g. "ab" means that this graph * has an edge between 'a' and 'b'). * * <p>The {@code successors} are always returned in alphabetical order. */
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 47.5K bytes - Viewed (0) -
guava-tests/test/com/google/common/graph/TraverserTest.java
} private static SuccessorsFunction<Character> createUndirectedGraph(String... edges) { return createGraph(/* directed= */ false, edges); } /** * Creates a graph from a list of node pairs (encoded as strings, e.g. "ab" means that this graph * has an edge between 'a' and 'b'). * * <p>The {@code successors} are always returned in alphabetical order. */
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 47.5K bytes - Viewed (0) -
cmd/erasure-server-pool-rebalance.go
if z.checkIfRebalanceDone(poolIdx) { return } fivs, err := entry.fileInfoVersions(bucket) if err != nil { return } // We need a reversed order for rebalance, // to create the appropriate stack. versionsSorter(fivs.Versions).reverse() var rebalanced, expired int for _, version := range fivs.Versions {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 13:20:19 UTC 2024 - 28.4K bytes - Viewed (0)