Search Options

Results per page
Sort
Preferred Languages
Advance

Results 41 - 50 of 68 for threadSafe (0.04 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. 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)
  8. 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)
  9. 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)
  10. 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)
Back to top