- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 68 for threadSafe (0.04 sec)
-
src/main/webapp/WEB-INF/view/admin/failureurl/admin_failureurl_details.jsp
<tr> <th><la:message key="labels.failure_url_thread_name"/></th> <td>${f:h(threadName)}<la:hidden property="threadName"/></td> </tr> <tr> <th><la:message key="labels.failure_url_error_name"/></th>
Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Thu Nov 13 05:54:52 UTC 2025 - 11K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/app/pager/FailureUrlPager.java
/** Current page number. */ private int currentPageNumber; /** ID of the failure URL record. */ public String id; /** Name of the thread that encountered the failure. */ public String threadName; /** Number of errors encountered for this URL. */ public String errorCount; /** Last time this URL was accessed. */ public String lastAccessTime; /**Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Thu Jul 17 08:28:31 UTC 2025 - 7K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/TestThread.java
private final SynchronousQueue<Response> responseQueue = new SynchronousQueue<>(); private @Nullable Throwable uncaughtThrowable = null; public TestThread(L lockLikeObject, String threadName) { super(threadName); this.lockLikeObject = checkNotNull(lockLikeObject); start(); } /* * TODO: b/318391980 - Once we test only under Java 20 and higher, avoid calling Thread.stop. As
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Dec 11 21:00:51 UTC 2025 - 11.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/opensearch/config/cbean/bs/BsFailureUrlCB.java
doColumn("errorName"); } public void columnLastAccessTime() { doColumn("lastAccessTime"); } public void columnThreadName() { doColumn("threadName"); } public void columnUrl() { doColumn("url"); } }
Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Sat Mar 15 06:53:53 UTC 2025 - 7K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/TestThread.java
private final SynchronousQueue<Response> responseQueue = new SynchronousQueue<>(); private @Nullable Throwable uncaughtThrowable = null; public TestThread(L lockLikeObject, String threadName) { super(threadName); this.lockLikeObject = checkNotNull(lockLikeObject); start(); } /* * TODO: b/318391980 - Once we test only under Java 20 and higher, avoid calling Thread.stop. As
Registered: Fri Dec 26 12:43:10 UTC 2025 - Last Modified: Thu Dec 11 21:00:51 UTC 2025 - 11.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/opensearch/config/bsbhv/BsFailureUrlBhv.java
result.setErrorName(DfTypeUtil.toString(source.get("errorName"))); result.setLastAccessTime(DfTypeUtil.toLong(source.get("lastAccessTime"))); result.setThreadName(DfTypeUtil.toString(source.get("threadName"))); result.setUrl(DfTypeUtil.toString(source.get("url"))); return updateEntity(source, result); } catch (InstantiationException | IllegalAccessException e) {
Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Sat Mar 15 06:53:53 UTC 2025 - 9.7K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/SystemHelper.java
if (current < percent) { return true; } final long startTime = getCurrentTimeAsLong(); final String threadName = Thread.currentThread().getName(); try { waitingThreadNames.add(threadName); while (current >= percent) { if (timeoutInMillis > 0 && getCurrentTimeAsLong() - startTime > timeoutInMillis) {
Registered: Sat Dec 20 09:19:18 UTC 2025 - Last Modified: Sat Dec 20 08:30:43 UTC 2025 - 36.6K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/connection/RealCall.kt
import okhttp3.internal.http.CallServerInterceptor import okhttp3.internal.http.RealInterceptorChain import okhttp3.internal.http.RetryAndFollowUpInterceptor import okhttp3.internal.platform.Platform import okhttp3.internal.threadName import okio.AsyncTimeout import okio.Timeout /** * Bridge between OkHttp's application and network layers. This class exposes high-level application * layer primitives: connections, requests, responses, and streams.
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Wed Nov 05 18:28:35 UTC 2025 - 19.7K bytes - Viewed (0) -
okhttp/src/commonJvmAndroid/kotlin/okhttp3/internal/-UtilJvm.kt
} } catch (_: SocketTimeoutException) { true // Read timed out; socket is good. } catch (_: IOException) { false // Couldn't read; socket is closed. } internal inline fun threadName( name: String, block: () -> Unit, ) { val currentThread = Thread.currentThread() val oldName = currentThread.name currentThread.name = name try { block() } finally {
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Thu Jul 31 04:18:40 UTC 2025 - 10.2K bytes - Viewed (1) -
okhttp/src/jvmTest/kotlin/okhttp3/internal/concurrent/TaskRunnerTest.kt
"FINE: Q10001 finished run in 0 µs: task two", ) } @Test fun taskNameIsUsedForThreadNameWhenRunning() { redQueue.execute("lucky task") { log += "run threadName:${Thread.currentThread().name}" } taskFaker.advanceUntil(0.µs) assertThat(log).containsExactly("run threadName:lucky task") taskFaker.assertNoMoreTasks()
Registered: Fri Dec 26 11:42:13 UTC 2025 - Last Modified: Wed Mar 19 19:25:20 UTC 2025 - 23K bytes - Viewed (0)