- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 17 for thread_name (0.21 sec)
-
src/test/java/org/codelibs/fess/it/CrawlTestBase.java
final List<Map<String, Object>> resList = new ArrayList<>(); for (Map<String, Object> elem : logList) { logger.info("config_id: {}, thread_name: {}", configId, elem.get("thread_name")); if (elem.containsKey("thread_name") && elem.get("thread_name").toString().startsWith("Crawler-" + configId.replace('-', '_'))) { resList.add(elem); } } return resList; }
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 9.9K bytes - Viewed (0) -
src/internal/trace/traceviewer/emitter.go
} e.threadMeta(format.ProcsSection, id, name, priority) } e.c.Flush() } func (e *Emitter) threadMeta(sectionID, tid uint64, name string, priority int) { e.Event(&format.Event{ Name: "thread_name", Phase: "M", PID: sectionID, TID: tid, Arg: &format.NameArg{Name: name}, }) e.Event(&format.Event{ Name: "thread_sort_index", Phase: "M", PID: sectionID, TID: tid,
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Nov 21 21:29:58 UTC 2023 - 20.4K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/es/config/cbean/ca/bs/BsFailureUrlCA.java
public void setThreadName_Terms(ConditionOptionCall<TermsAggregationBuilder> opLambda) { setThreadName_Terms("threadName", opLambda, null); } public void setThreadName_Terms(ConditionOptionCall<TermsAggregationBuilder> opLambda, OperatorCall<BsFailureUrlCA> aggsLambda) { setThreadName_Terms("threadName", opLambda, aggsLambda); }
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 46.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/es/config/bsentity/dbmeta/FailureUrlDbm.java
null, false, false, false, "Long", 0, 0, null, null, false, null, null, null, null, null, false); protected final ColumnInfo _columnThreadName = cci("threadName", "threadName", null, null, String.class, "threadName", null, false, false, false, "keyword", 0, 0, null, null, false, null, null, null, null, null, false);
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Thu Feb 22 01:37:57 UTC 2024 - 10.2K 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(); } // Thread.stop() is okay because all threads started by a test are dying at the end of the test,
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Jun 11 16:13:05 UTC 2024 - 10.8K 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(); } // Thread.stop() is okay because all threads started by a test are dying at the end of the test,
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Jun 11 16:13:05 UTC 2024 - 10.8K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/SystemHelper.java
return; } short current = getSystemCpuPercent(); if (current < percent) { return; } final String threadName = Thread.currentThread().getName(); try { waitingThreadNames.add(threadName); while (current >= percent) { if (logger.isInfoEnabled()) {
Registered: Wed Jun 12 13:08:18 UTC 2024 - Last Modified: Sun May 26 05:52:29 UTC 2024 - 26.5K bytes - Viewed (0) -
okhttp/src/main/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: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Sat Apr 20 17:03:43 UTC 2024 - 17.9K bytes - Viewed (0) -
okhttp/src/main/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: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon May 13 13:42:37 UTC 2024 - 10.7K bytes - Viewed (0) -
okhttp/src/test/java/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: Sun Jun 16 04:42:17 UTC 2024 - Last Modified: Mon Apr 29 00:33:04 UTC 2024 - 23K bytes - Viewed (0)