- Sort Score
- Result 10 results
- Languages All
Results 191 - 200 of 643 for john (0.02 sec)
-
guava-tests/test/com/google/common/util/concurrent/ExecutionListTest.java
Thread thread1 = new Thread(execute); Thread thread2 = new Thread(execute); thread1.start(); thread2.start(); assertEquals(0, runCalled.get()); okayToRun.countDown(); thread1.join(); thread2.join(); assertEquals(1, runCalled.get()); } public void testAddAfterRun() throws Exception { // Run the previous test testRunOnPopulatedList();
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 22:10:29 UTC 2024 - 4.7K bytes - Viewed (0) -
utils/utils.go
default: results[idx] = "nil" vv := reflect.ValueOf(v) if vv.IsValid() && !vv.IsZero() { results[idx] = fmt.Sprint(reflect.Indirect(vv).Interface()) } } } return strings.Join(results, "_") } func Contains(elems []string, elem string) bool { for _, e := range elems { if elem == e { return true } } return false } func AssertEqual(x, y interface{}) bool {
Registered: Sun Nov 03 09:35:10 UTC 2024 - Last Modified: Thu Aug 22 11:03:42 UTC 2024 - 4.1K bytes - Viewed (0) -
build-logic/binary-compatibility/src/main/groovy/gradlebuild/binarycompatibility/rules/NullabilityBreakingChangesRule.groovy
if (!errors.isEmpty()) { def changes = errors + warnings return acceptOrReject(member, changes, Violation.error(member, changes.join(" "))) } if (!warnings.isEmpty()) { return Violation.warning(member, warnings.join(" ")) } return null } private static List<Boolean> parametersNullabilityOf(CtBehavior behavior) {
Registered: Wed Nov 06 11:36:14 UTC 2024 - Last Modified: Sat Apr 13 10:04:28 UTC 2024 - 5.4K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/ExecutionListTest.java
Thread thread1 = new Thread(execute); Thread thread2 = new Thread(execute); thread1.start(); thread2.start(); assertEquals(0, runCalled.get()); okayToRun.countDown(); thread1.join(); thread2.join(); assertEquals(1, runCalled.get()); } public void testAddAfterRun() throws Exception { // Run the previous test testRunOnPopulatedList();
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 22:10:29 UTC 2024 - 4.7K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/MoreExecutorsTest.java
ListenableFuture<?> future = executor.submit(incrementTask); assertTrue(future.isDone()); assertListenerRunImmediately(future); assertEquals(1, threadLocalCount.get().intValue()); otherThread.join(1000); assertEquals(Thread.State.TERMINATED, otherThread.getState()); Throwable throwable = throwableFromOtherThread.get(); assertNull( "Throwable from other thread: "
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Fri Oct 18 22:10:29 UTC 2024 - 28.1K bytes - Viewed (0) -
cni/pkg/nodeagent/server.go
log.Errorf("failed to annotate pod unenrollment: %v", err) errs = append(errs, err) return errors.Join(errs...) } return errors.Join(errs...) } // syncHostIPSets is called after the host node ipset has been created (or found + flushed) // during initial snapshot creation, it will insert every snapshotted pod's IP into the set. //
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Wed Sep 25 20:54:34 UTC 2024 - 13.4K bytes - Viewed (0) -
android/guava/src/com/google/thirdparty/publicsuffix/TrieParser.java
* 64k limit on string literal size. In-memory strings can be much larger (2G). */ static ImmutableMap<String, PublicSuffixType> parseTrie(CharSequence... encodedChunks) { String encoded = DIRECT_JOINER.join(encodedChunks); return parseFullString(encoded); } @VisibleForTesting static ImmutableMap<String, PublicSuffixType> parseFullString(String encoded) {
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Oct 13 19:20:43 UTC 2022 - 4K bytes - Viewed (0) -
schema/schema_helper_test.go
} if r.JoinTable != nil { if r.JoinTable.Name != relation.JoinTable.Name { t.Errorf("schema %v relation's join table name expects %v, but got %v", s, relation.JoinTable.Name, r.JoinTable.Name) } if r.JoinTable.Table != relation.JoinTable.Table { t.Errorf("schema %v relation's join table tablename expects %v, but got %v", s, relation.JoinTable.Table, r.JoinTable.Table) }
Registered: Sun Nov 03 09:35:10 UTC 2024 - Last Modified: Fri Dec 15 08:31:23 UTC 2023 - 7.5K bytes - Viewed (0) -
cni/pkg/install/install.go
// NewInstaller returns an instance of Installer with the given config func NewInstaller(cfg *config.InstallConfig, isReady *atomic.Value) *Installer { return &Installer{ cfg: cfg, kubeconfigFilepath: filepath.Join(cfg.CNIAgentRunDir, constants.CNIPluginKubeconfName), isReady: isReady, } } func (in *Installer) installAll(ctx context.Context) (sets.String, error) { // Install binaries
Registered: Wed Nov 06 22:53:10 UTC 2024 - Last Modified: Fri Aug 09 21:33:51 UTC 2024 - 13.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/job/CrawlJob.java
cmdList.add(StringUtils.join(webConfigIds, ',')); } if (fileConfigIds != null && fileConfigIds.length > 0) { cmdList.add("-f"); cmdList.add(StringUtils.join(fileConfigIds, ',')); } if (dataConfigIds != null && dataConfigIds.length > 0) { cmdList.add("-d"); cmdList.add(StringUtils.join(dataConfigIds, ',')); }
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Sun Jun 23 04:13:47 UTC 2024 - 15.1K bytes - Viewed (0)