- Sort Score
- Result 10 results
- Languages All
Results 1911 - 1920 of 5,478 for newE (0.02 sec)
-
guava/src/com/google/common/util/concurrent/CycleDetectingLockFactory.java
return policy == Policies.DISABLED ? new ReentrantReadWriteLock(fair) : new CycleDetectingReentrantReadWriteLock(new LockGraphNode(lockName), fair); } // A static mapping from an Enum type to its set of LockGraphNodes. private static final ConcurrentMap< Class<? extends Enum<?>>, Map<? extends Enum<?>, LockGraphNode>> lockGraphNodesPerType = new MapMaker().weakKeys().makeMap();Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Sep 11 17:06:34 UTC 2025 - 35.9K bytes - Viewed (0) -
samples/guide/src/main/java/okhttp3/recipes/PostFile.java
public static final MediaType MEDIA_TYPE_MARKDOWN = MediaType.get("text/x-markdown; charset=utf-8"); private final OkHttpClient client = new OkHttpClient(); public void run() throws Exception { File file = new File("README.md"); Request request = new Request.Builder() .url("https://api.github.com/markdown/raw") .post(RequestBody.create(file, MEDIA_TYPE_MARKDOWN)) .build();Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Sat May 25 18:02:55 UTC 2019 - 1.5K bytes - Viewed (0) -
internal/bpool/pool.go
// Pool is a single type sync.Pool with a few extra properties: // If New is not set Get may return the zero value of T. type Pool[T any] struct { New func() T p sync.Pool } // Get will retuen a new T func (p *Pool[T]) Get() T { v, ok := p.p.Get().(T) if ok { return v } if p.New == nil { var t T return t } return p.New() } // Put a used T. func (p *Pool[T]) Put(t T) { p.p.Put(t)
Registered: Sun Dec 28 19:28:13 UTC 2025 - Last Modified: Tue Feb 18 16:25:55 UTC 2025 - 1.2K bytes - Viewed (0) -
compat/maven-plugin-api/src/main/java/org/apache/maven/plugin/descriptor/PluginDescriptor.java
if (pluginFile == null) { throw new IllegalStateException("plugin main artifact has not been resolved for " + getId()); } if (pluginFile.isFile()) { try { return new URL("jar:" + pluginFile.toURI() + "!/" + descriptor).openStream(); } catch (MalformedURLException e) { throw new IllegalStateException(e); } } else {
Registered: Sun Dec 28 03:35:09 UTC 2025 - Last Modified: Fri Jun 06 14:28:57 UTC 2025 - 16.2K bytes - Viewed (0) -
guava-tests/test/com/google/common/collect/ContiguousSetTest.java
} private static final DiscreteDomain<Integer> UNBOUNDED_THROWING_DOMAIN = new DiscreteDomain<Integer>() { @Override public Integer next(Integer value) { throw new AssertionError(); } @Override public Integer previous(Integer value) { throw new AssertionError(); } @Override
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Aug 07 16:05:33 UTC 2025 - 19.6K bytes - Viewed (0) -
guava/src/com/google/common/collect/ArrayListMultimap.java
* given key agrees with the order in which the values were added. * * <p>This multimap allows duplicate key-value pairs. After adding a new key-value pair equal to an * existing key-value pair, the {@code ArrayListMultimap} will contain entries for both the new * value and the old value. * * <p>Keys and values may be null. All optional multimap methods are supported, and all returned * views are modifiable. *Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Fri Dec 05 23:15:58 UTC 2025 - 6.8K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/AbstractScheduledService.java
checkNotNull(unit); checkArgument(delay > 0, "delay must be > 0, found %s", delay); return new Scheduler() { @Override public Cancellable schedule( AbstractService service, ScheduledExecutorService executor, Runnable task) { return new FutureAsCancellable( executor.scheduleWithFixedDelay(task, initialDelay, delay, unit)); } }; }
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Sat Aug 09 01:14:59 UTC 2025 - 27.8K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ClosingFuture.java
checkNotNull(callable); CloseableList closeables = new CloseableList(); TrustedListenableFutureTask<V> task = TrustedListenableFutureTask.create( new AsyncCallable<V>() { @Override public ListenableFuture<V> call() throws Exception { CloseableList newCloseables = new CloseableList(); try {
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Sep 11 13:51:27 UTC 2025 - 96.9K bytes - Viewed (0) -
fess-crawler/src/test/java/org/codelibs/fess/crawler/CrawlerThreadTest.java
private RuleManager ruleManager; @Override @SuppressWarnings("unchecked") protected void setUp() throws Exception { super.setUp(); crawlerThread = new CrawlerThread(); crawlerContext = new CrawlerContext(); crawlerContext.sessionId = "test-session"; crawlerContext.numOfThread = 1; crawlerContext.maxThreadCheckCount = 10; crawlerContext.maxDepth = 3;Registered: Sat Dec 20 11:21:39 UTC 2025 - Last Modified: Mon Nov 24 03:59:47 UTC 2025 - 18.3K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/web/base/login/OpenIdConnectCredential.java
/** * OpenID Connect credential implementation. */ public class OpenIdConnectCredential implements LoginCredential, FessCredential { private final Map<String, Object> attributes; /** * Creates a new OpenID Connect credential. * * @param attributes the attributes from OpenID Connect provider */ public OpenIdConnectCredential(final Map<String, Object> attributes) { this.attributes = attributes;Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 5.1K bytes - Viewed (0)