Search Options

Results per page
Sort
Preferred Languages
Advance

Results 341 - 350 of 622 for continua (0.06 sec)

  1. android/guava/src/com/google/common/base/Ascii.java

          char c2 = s2.charAt(i);
          if (c1 == c2) {
            continue;
          }
          int alphaIndex = getAlphaIndex(c1);
          // This was also benchmarked using '&' to avoid branching (but always evaluate the rhs),
          // however this showed no obvious improvement.
          if (alphaIndex < 26 && alphaIndex == getAlphaIndex(c2)) {
            continue;
          }
          return false;
        }
        return true;
      }
    
    Registered: Fri Dec 26 12:43:10 UTC 2025
    - Last Modified: Mon Mar 17 20:26:29 UTC 2025
    - 21.7K bytes
    - Viewed (0)
  2. docs/en/docs/async.md

    Instead of that, by being an "asynchronous" system, once finished, the task can wait in line a little bit (some microseconds) for the computer / program to finish whatever it went to do, and then come back to take the results and continue working with them.
    
    Registered: Sun Dec 28 07:19:09 UTC 2025
    - Last Modified: Sun Aug 31 09:56:21 UTC 2025
    - 24K bytes
    - Viewed (0)
  3. cmd/metrics-v3-handler.go

    			// metric group, so that it will affect collection. If no buckets
    			// are provided, we will not return bucket metrics.
    			if bmg, ok := h.metricsData.bucketMGMap[collectorPath]; ok {
    				if len(buckets) == 0 {
    					continue
    				}
    				unLocker := bmg.LockAndSetBuckets(buckets)
    				defer unLocker()
    			}
    			gatherers = append(gatherers, gatherer)
    		}
    	}
    
    	if len(gatherers) == 0 {
    		return notFoundHandler
    	}
    
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Oct 10 18:57:03 UTC 2025
    - 7.7K bytes
    - Viewed (0)
  4. internal/s3select/json/preader.go

    				return
    			}
    		}
    	}()
    
    	// Start parsers
    	for range runtime.GOMAXPROCS(0) {
    		go func() {
    			for in := range r.input {
    				if len(in.input) == 0 {
    					in.dst <- nil
    					continue
    				}
    				dst := r.kvDstPool.Get()
    				if len(dst) < 1000 {
    					dst = make([]jstream.KVS, 0, 1000)
    				}
    
    				d := jstream.NewDecoder(bytes.NewBuffer(in.input), 0).ObjectAsKVS().MaxDepth(100)
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue May 27 15:19:03 UTC 2025
    - 6.5K bytes
    - Viewed (0)
  5. api/maven-api-core/src/main/java/org/apache/maven/api/services/ProblemCollector.java

                            try {
                                return problems.remove(0) != null;
                            } catch (IndexOutOfBoundsException e) {
                                // empty, continue
                            }
                        }
                    }
                }
                return false;
            }
        }
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Fri Jul 18 17:30:19 UTC 2025
    - 11.4K bytes
    - Viewed (0)
  6. impl/maven-cli/src/test/java/org/apache/maven/cling/invoker/mvnup/goals/StrategyOrchestratorTest.java

                UpgradeResult result = orchestrator.executeStrategies(context, pomMap);
    
                // The orchestrator may handle exceptions gracefully and continue
                assertNotNull(result, "Result should not be null");
                // We can't guarantee failure behavior without knowing the exact implementation
            }
        }
    
        @Nested
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Tue Nov 18 18:03:26 UTC 2025
    - 12.3K bytes
    - Viewed (0)
  7. callbacks.go

    	}
    
    	return
    }
    
    func removeCallbacks(cs []*callback, nameMap map[string]bool) []*callback {
    	callbacks := make([]*callback, 0, len(cs))
    	for _, callback := range cs {
    		if nameMap[callback.name] {
    			continue
    		}
    		callbacks = append(callbacks, callback)
    	}
    	return callbacks
    Registered: Sun Dec 28 09:35:17 UTC 2025
    - Last Modified: Tue Aug 26 06:24:29 UTC 2025
    - 8.8K bytes
    - Viewed (0)
  8. okhttp/src/commonJvmAndroid/kotlin/okhttp3/Dispatcher.kt

            while (i.hasNext()) {
              val asyncCall = i.next()
    
              if (runningAsyncCalls.size >= this.maxRequests) break // Max capacity.
              if (asyncCall.callsPerHost.get() >= this.maxRequestsPerHost) continue // Host max capacity.
    
              i.remove()
    
              asyncCall.callsPerHost.incrementAndGet()
              callsToExecute.add(asyncCall)
              runningAsyncCalls.add(asyncCall)
            }
    
    Registered: Fri Dec 26 11:42:13 UTC 2025
    - Last Modified: Tue Oct 07 14:16:22 UTC 2025
    - 9.9K bytes
    - Viewed (0)
  9. impl/maven-core/src/main/java/org/apache/maven/execution/ProjectActivation.java

        }
    
        /**
         * Adds a project activation to the request.
         * @param selector The selector of the project.
         * @param active Should the project be activated?
         * @param optional Can the build continue if the project does not exist?
         */
        public void addProjectActivation(String selector, boolean active, boolean optional) {
            final ActivationSettings settings = ActivationSettings.of(active, optional);
    Registered: Sun Dec 28 03:35:09 UTC 2025
    - Last Modified: Tue Feb 11 16:38:19 UTC 2025
    - 7.2K bytes
    - Viewed (0)
  10. cmd/metacache-manager.go

    	// holding lock to m all the time.
    	b.mu.Lock()
    	defer b.mu.Unlock()
    	for k, v := range b.caches {
    		if time.Since(v.lastUpdate) > metacacheMaxRunningAge {
    			v.delete(context.Background())
    			continue
    		}
    		v.error = "Bucket deleted"
    		v.status = scanStateError
    		m.mu.Lock()
    		m.trash[k] = v
    		m.mu.Unlock()
    	}
    }
    
    // deleteAll will delete all caches.
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Tue Oct 25 00:44:15 UTC 2022
    - 5.2K bytes
    - Viewed (0)
Back to top