- Sort Score
- Result 10 results
- Languages All
Results 11 - 20 of 23 for isLocked (0.51 sec)
-
maven-compat/src/main/java/org/apache/maven/repository/legacy/LegacyRepositorySystem.java
effectiveRepository.setProxy(aliasedRepo.getProxy()); effectiveRepository.setMirroredRepositories(mirroredRepos); effectiveRepository.setBlocked(aliasedRepo.isBlocked()); effectiveRepositories.add(effectiveRepository); } return effectiveRepositories; }
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Thu Sep 14 11:48:15 UTC 2023 - 31.6K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java
// nothing } } void awaitWaiting() { while (!isBlocked()) { if (getState() == State.TERMINATED) { throw new RuntimeException("Thread exited"); } Thread.yield(); } } private boolean isBlocked() { return getState() == Thread.State.WAITING && LockSupport.getBlocker(this) == future; } }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Jun 11 16:13:05 UTC 2024 - 46.7K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/bridge/MavenRepositorySystem.java
mirror.setId(repo.getId()); mirror.setUrl(repo.getUrl()); mirror.setLayout(repo.getContentType()); mirror.setBlocked(repo.isBlocked()); return mirror; } } } return null; }
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Sat Feb 17 18:40:11 UTC 2024 - 32.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java
// nothing } } void awaitWaiting() { while (!isBlocked()) { if (getState() == State.TERMINATED) { throw new RuntimeException("Thread exited"); } Thread.yield(); } } private boolean isBlocked() { return getState() == Thread.State.WAITING && LockSupport.getBlocker(this) == future; } }
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Jun 11 16:13:05 UTC 2024 - 46.7K bytes - Viewed (0) -
subprojects/core/src/testFixtures/groovy/org/gradle/util/internal/MultithreadedTestRule.java
return Thread.currentThread() == thread; } public boolean isBlocked() { return blockedStates.contains(thread.getState()); } @Override public void waitUntilBlocked() { long expiry = System.currentTimeMillis() + 2000L; while (!isBlocked()) { if (System.currentTimeMillis() > expiry) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Oct 05 19:36:14 UTC 2023 - 23.3K bytes - Viewed (0) -
maven-compat/src/main/java/org/apache/maven/artifact/repository/LegacyLocalRepositoryManager.java
return Collections.emptyList(); } public void setMirroredRepositories(List<ArtifactRepository> mirroredRepositories) {} public boolean isBlocked() { return false; } public void setBlocked(boolean blocked) {} }
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Wed Feb 28 07:40:37 UTC 2024 - 12.2K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/RepositoryUtils.java
builder.setProxy(toProxy(repo.getProxy())); builder.setMirroredRepositories(toRepos(repo.getMirroredRepositories())); builder.setBlocked(repo.isBlocked()); result = builder.build(); } return result; } public static String getLayout(ArtifactRepository repo) { try { return repo.getLayout().getId();
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Wed Feb 28 07:40:37 UTC 2024 - 16K bytes - Viewed (0) -
cmd/endpoint.go
endpoints[i].Hostname()), endpoints[i].Hostname(), logger.ErrorKind) } continue } // return err if not Docker or Kubernetes // We use IsDocker() to check for Docker environment // We use IsKubernetes() to check for Kubernetes environment isLocal, err := isLocalHost(endpoints[i].Hostname(), endpoints[i].Port(), globalMinioPort, )
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 34.1K bytes - Viewed (0) -
maven-core/src/main/java/org/apache/maven/internal/aether/DefaultRepositorySystemSessionFactory.java
mirrorSelector.add( mirror.getId(), mirror.getUrl(), mirror.getLayout(), false, mirror.isBlocked(), mirror.getMirrorOf(), mirror.getMirrorOfLayouts()); } sessionBuilder.setMirrorSelector(mirrorSelector);
Registered: Wed Jun 12 09:55:16 UTC 2024 - Last Modified: Thu Apr 25 14:13:36 UTC 2024 - 27.5K bytes - Viewed (0) -
guava/src/com/google/common/base/Converter.java
* existing users, but it can't *fix* existing users because any users who needed * `Function<@Nullable A, @Nullable B>` already had to find a workaround. Still, there is a *ton* of * fallout from trying to switch. I would be shocked if the switch would offer benefits to anywhere * near enough users to justify the costs. * * Fortunately, if anyone does want to use a Converter as a `Function<@Nullable A, @Nullable B>`,
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Thu Feb 15 16:12:13 UTC 2024 - 23K bytes - Viewed (0)