- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 1,387 for Take (0.01 sec)
-
impl/maven-core/src/main/java/org/apache/maven/lifecycle/internal/builder/multithreaded/MultiThreadedBuilder.java
service.submit(cb); } // for each finished project for (int i = 0; i < analyzer.getNumberOfBuilds(); i++) { try { ProjectSegment projectBuild = service.take().get(); if (reactorContext.getReactorBuildStatus().isHalted()) { break; }
Registered: Sun Dec 28 03:35:09 UTC 2025 - Last Modified: Wed Jul 16 03:42:09 UTC 2025 - 8.9K bytes - Viewed (0) -
internal/http/server.go
return int(atomic.LoadInt32(&srv.requestCount)) } // Init - init HTTP server func (srv *Server) Init(listenCtx context.Context, listenErrCallback func(listenAddr string, err error)) (serve func() error, err error) { // Take a copy of server fields. var tlsConfig *tls.Config if srv.TLSConfig != nil { tlsConfig = srv.TLSConfig.Clone() } handler := srv.Handler // if srv.Handler holds non-synced state -> possible data race
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Sun Sep 28 20:59:21 UTC 2025 - 6.5K bytes - Viewed (0) -
docs/en/docs/history-design-future.md
</blockquote> ## Investigation { #investigation } By using all the previous alternatives I had the chance to learn from all of them, take ideas, and combine them in the best way I could find for myself and the teams of developers I have worked with. For example, it was clear that ideally it should be based on standard Python type hints.Registered: Sun Dec 28 07:19:09 UTC 2025 - Last Modified: Sat Oct 11 17:48:49 UTC 2025 - 4.2K bytes - Viewed (0) -
okhttp/src/jvmTest/kotlin/okhttp3/FakeRoutePlanner.kt
require(nextPlanIndex < plans.size) { "not enough plans! call addPlan() or set autoGeneratePlans=true in the test to set this up" } val result = plans[nextPlanIndex++] events += "take plan ${result.id}" if (result.yieldBeforePlanReturns) { taskFaker.yield() } val planningThrowable = result.planningThrowable if (planningThrowable != null) throw planningThrowableRegistered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Tue Oct 07 21:55:03 UTC 2025 - 6.1K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/collect/ComparatorsTest.java
assertThat(max(1, 2, reverse)).isEqualTo(1); assertThat(max(2, 1, reverse)).isEqualTo(1); } /** * Fails compilation if the signature of min and max is changed to take {@code Comparator<T>} * instead of {@code Comparator<? super T>}. */ public void testMinMaxWithSupertypeComparator() { Comparator<Number> numberComparator = comparing(Number::intValue);
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Sat Apr 12 15:07:59 UTC 2025 - 6.4K bytes - Viewed (0) -
docs/en/docs/tutorial/body-updates.md
```Python { "name": "Barz", "price": 3, "description": None, } ``` because it doesn't include the already stored attribute `"tax": 20.2`, the input model would take the default value of `"tax": 10.5`. And the data would be saved with that "new" `tax` of `10.5`. ## Partial updates with `PATCH` { #partial-updates-with-patch }Registered: Sun Dec 28 07:19:09 UTC 2025 - Last Modified: Sat Dec 20 15:55:38 UTC 2025 - 4.1K bytes - Viewed (0) -
cmd/listen-notification-handlers.go
// Listen Publisher and peer-listen-client uses nonblocking send and hence does not wait for slow receivers. // Use buffered channel to take care of burst sends or slow w.Write() mergeCh := make(chan []byte, globalAPIConfig.getRequestsPoolCapacity()*len(globalEndpoints.Hostnames())) localCh := make(chan event.Event, globalAPIConfig.getRequestsPoolCapacity()) // Convert local messages to JSON and send to mergeCh go func() {
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Tue Feb 18 16:25:55 UTC 2025 - 6K bytes - Viewed (0) -
code_of_conduct.md
professional setting ## Our Responsibilities Project maintainers are responsible for clarifying the standards of acceptable behavior and are expected to take appropriate and fair corrective action in response to any instances of unacceptable behavior, in compliance with the licensing terms applying to the Project developments.
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Mon Jan 20 18:38:58 UTC 2020 - 3.5K bytes - Viewed (0) -
okhttp-testing-support/src/main/kotlin/okhttp3/internal/concurrent/TaskFaker.kt
/** How many times a new task has been started. Guarded by `this`. */ private var contextSwitchCount = 0 /** Guarded by `this`. */ private var activeThreads = 0 /** A task runner that posts tasks to this fake. Tasks won't be executed until requested. */ val taskRunner: TaskRunner = TaskRunner( object : TaskRunner.Backend { override fun execute( taskRunner: TaskRunner, runnable: Runnable,
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Wed May 28 23:28:25 UTC 2025 - 11.9K bytes - Viewed (0) -
android/guava/src/com/google/common/hash/Hashing.java
* generated using this are byte-wise identical to those created using the C++ version, but note * that this uses unsigned integers (see {@link com.google.common.primitives.UnsignedInts}). * Comparisons between the two should take this into account. * * <p>Fingerprint2011() is a form of Murmur2 on strings up to 32 bytes and a form of CityHash for * longer strings. It could have been one or the other throughout. The main advantage of the
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Jul 17 15:26:41 UTC 2025 - 29.8K bytes - Viewed (0)