- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of about 10,000 for finalA (0.16 sec)
-
platforms/ide/tooling-api/src/main/java/org/gradle/tooling/internal/consumer/async/ServiceLifecycle.java
*/ public class ServiceLifecycle implements AsyncStoppable { private enum State {RUNNING, STOPPING, STOPPED} private final String displayName; private final Lock lock = new ReentrantLock(); private final Condition condition = lock.newCondition(); private final Map<Thread, Integer> usages = new HashMap<>(); private State state = State.RUNNING; public ServiceLifecycle(String displayName) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 11 19:07:55 UTC 2024 - 4K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/extractor/impl/LhaExtractor.java
private static final Logger logger = LoggerFactory.getLogger(LhaExtractor.class); protected long maxContentSize = -1; @Override public ExtractData getText(final InputStream in, final Map<String, String> params) { if (in == null) { throw new CrawlerSystemException("The inputstream is null."); } final MimeTypeHelper mimeTypeHelper = getMimeTypeHelper();
Registered: Wed Jun 12 15:17:51 UTC 2024 - Last Modified: Thu Feb 22 01:36:27 UTC 2024 - 4.8K bytes - Viewed (0) -
fess-crawler/src/test/java/org/codelibs/fess/crawler/client/ftp/FtpClientTest.java
ftpClient.doGet("ftp://localhost:" + FTP_PORT + "/"); fail(); } catch (final ChildUrlsException e) { final Set<RequestData> urlSet = e.getChildUrlList(); assertEquals(5, urlSet.size()); for (final RequestData requestData : urlSet.toArray(new RequestData[urlSet.size()])) { String url = requestData.getUrl();
Registered: Wed Jun 12 15:17:51 UTC 2024 - Last Modified: Thu Feb 22 01:36:27 UTC 2024 - 16.3K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/test/fixtures/server/http/ExpectMaxNConcurrentRequests.java
private final Lock lock; private final Condition condition; private final List<ResourceHandlerWrapper> received = new ArrayList<>(); private final List<ResourceHandlerWrapper> released = new ArrayList<>(); private final LinkedList<ResourceHandlerWrapper> notReleased = new LinkedList<>(); private final List<ResourceHandlerWrapper> notReceived = new ArrayList<>();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 14.4K bytes - Viewed (0) -
fess-crawler/src/main/java/org/codelibs/fess/crawler/CrawlerThread.java
} } protected void storeChildUrls(final Set<RequestData> childUrlList, final String url, final int depth) { if (crawlerContext.getMaxDepth() >= 0 && depth > crawlerContext.getMaxDepth()) { return; } // add url and filter final Set<String> urlSet = new HashSet<>();
Registered: Wed Jun 12 15:17:51 UTC 2024 - Last Modified: Thu Feb 22 01:36:27 UTC 2024 - 15.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/job/ScriptExecutorJob.java
protected void process(final LaJobRuntime runtime) { if (!runtime.getParameterMap().containsKey(Constants.SCHEDULED_JOB)) { logger.warn("{} is empty.", Constants.SCHEDULED_JOB); return; } runtime.stopIfNeeds(); final SystemHelper systemHelper = ComponentUtil.getSystemHelper(); final JobManager jobManager = ComponentUtil.getJobManager();
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 5.3K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/internal/DefaultFileLockManager.java
private static final Logger LOGGER = LoggerFactory.getLogger(DefaultFileLockManager.class); public static final int DEFAULT_LOCK_TIMEOUT = 60000; private final Set<File> lockedFiles = new CopyOnWriteArraySet<>(); private final ProcessMetaDataProvider metaDataProvider; private final int lockTimeoutMs; private final LongSupplier generator; private final FileLockContentionHandler fileLockContentionHandler;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Apr 26 16:02:32 UTC 2024 - 22.3K bytes - Viewed (0) -
fess-crawler/src/test/java/org/codelibs/fess/crawler/client/http/HcHttpClientTest.java
final String value = "Mon, 01 Jun 2009 21:02:45 GMT"; final Date date = httpClient.parseLastModified(value); assertNotNull(date); } public void test_processRobotsTxt() { final CrawlerWebServer server = new CrawlerWebServer(7070); server.start(); final String url = "http://localhost:7070/hoge.html"; try {
Registered: Wed Jun 12 15:17:51 UTC 2024 - Last Modified: Thu May 09 09:28:25 UTC 2024 - 8.8K bytes - Viewed (0) -
platforms/core-runtime/concurrent/src/main/java/org/gradle/internal/concurrent/InterruptibleRunnable.java
* This can be used to implement guaranteed delivery mechanisms, where proper interrupt handling is up to the delegate. */ public final class InterruptibleRunnable implements Runnable { private final Lock stateLock = new ReentrantLock(); private final Runnable delegate; private boolean interrupted; private Thread thread; public InterruptibleRunnable(Runnable delegate) {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 11 19:07:35 UTC 2024 - 2.4K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/Monitor.java
* * <pre>{@code * public class SafeBox<V> { * private V value; * private final ReentrantLock lock = new ReentrantLock(); * private final Condition valuePresent = lock.newCondition(); * private final Condition valueAbsent = lock.newCondition(); * * public V get() throws InterruptedException { * lock.lock(); * try {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Dec 04 18:22:01 UTC 2023 - 38.6K bytes - Viewed (0)