Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 31 for QThread (0.15 sec)

  1. src/main/java/org/codelibs/fess/exec/ThumbnailGenerator.java

                SingletonLaContainerFactory.setExternalContextComponentDefRegister(new GenericExternalContextComponentDefRegister());
                SingletonLaContainerFactory.init();
    
                final Thread shutdownCallback = new Thread("ShutdownHook") {
                    @Override
                    public void run() {
                        if (logger.isDebugEnabled()) {
                            logger.debug("Destroying LaContainer..");
    Java
    - Registered: Mon May 06 08:04:11 GMT 2024
    - Last Modified: Thu Feb 22 01:37:57 GMT 2024
    - 8.2K bytes
    - Viewed (0)
  2. src/main/java/org/codelibs/fess/app/service/FailureUrlService.java

            failureUrl.setErrorName(errorName);
            failureUrl.setErrorLog(getStackTrace(e));
            failureUrl.setLastAccessTime(ComponentUtil.getSystemHelper().getCurrentTimeAsLong());
            failureUrl.setThreadName(Thread.currentThread().getName());
    
            bhv.insertOrUpdate(failureUrl, op -> {
                op.setRefreshPolicy(Constants.TRUE);
            });
        }
    
        private String getStackTrace(final Throwable t) {
    Java
    - Registered: Mon May 06 08:04:11 GMT 2024
    - Last Modified: Thu Feb 22 01:37:57 GMT 2024
    - 6.3K bytes
    - Viewed (0)
  3. src/main/java/jcifs/smb1/smb1/SmbNamedPipe.java

         * read-only named pipe would write data to this stream on
         * connection). Reading from this stream may block. Therefore it
         * may be necessary that an addition thread be used to read and
         * write to a Named Pipe.
         */
    
        public InputStream getNamedPipeInputStream() throws IOException {
            if( pipeIn == null ) {
    Java
    - Registered: Sun May 05 00:10:10 GMT 2024
    - Last Modified: Fri Mar 22 21:10:40 GMT 2019
    - 7.3K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/core/lang/ThreadUtil.java

    import org.codelibs.core.log.Logger;
    
    /**
     * Utility class for Thread class
     *
     * @author shinsuke
     *
     */
    public abstract class ThreadUtil {
    
        private static final Logger logger = Logger.getLogger(ThreadUtil.class);
    
        public static void sleep(final long millis) {
            if (millis < 1L) {
                return;
            }
            try {
                Thread.sleep(millis);
            } catch (final InterruptedException e) {
    Java
    - Registered: Fri May 03 20:58:11 GMT 2024
    - Last Modified: Thu Mar 07 01:59:08 GMT 2024
    - 1.5K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/util/ThreadDumpUtil.java

                });
            } catch (final Exception e) {
                logger.warn("Failed to write a thread dump to {}", file, e);
            }
        }
    
        public static void processThreadDump(final Consumer<String> writer) {
            for (final Map.Entry<Thread, StackTraceElement[]> entry : Thread.getAllStackTraces().entrySet()) {
                writer.accept("Thread: " + entry.getKey());
                final StackTraceElement[] trace = entry.getValue();
    Java
    - Registered: Mon May 06 08:04:11 GMT 2024
    - Last Modified: Thu Feb 22 01:37:57 GMT 2024
    - 2.5K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/helper/ActivityHelper.java

            buf.append(",\"service.name\":\"").append(ecsServiceName).append('"');
            buf.append(",\"event.dataset\":\"").append(ecsEventDataset).append('"');
            buf.append(",\"process.thread.name\":\"").append(StringEscapeUtils.escapeJson(Thread.currentThread().getName())).append('"');
            buf.append(",\"log.logger\":\"").append(StringEscapeUtils.escapeJson(this.getClass().getName())).append('"');
    Java
    - Registered: Mon May 06 08:04:11 GMT 2024
    - Last Modified: Thu Feb 22 01:37:57 GMT 2024
    - 7.7K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/core/lang/ClassLoaderUtil.java

         *             クラスローダを取得できなかった場合
         */
        public static ClassLoader getClassLoader(final Class<?> targetClass) {
            assertArgumentNotNull("targetClass", targetClass);
    
            final ClassLoader contextClassLoader = Thread.currentThread().getContextClassLoader();
            if (contextClassLoader != null) {
                return contextClassLoader;
            }
    
            final ClassLoader targetClassLoader = targetClass.getClassLoader();
    Java
    - Registered: Fri May 03 20:58:11 GMT 2024
    - Last Modified: Thu Mar 07 01:59:08 GMT 2024
    - 8.2K bytes
    - Viewed (0)
  8. src/test/java/org/codelibs/fess/it/admin/ReqHeaderTests.java

            requestBody.put("name", "test_webconfig");
            requestBody.put("urls", "http://www.example.com");
            requestBody.put("user_agent", "Mozilla/5.0");
            requestBody.put("num_of_thread", 5);
            requestBody.put("interval_time", 1000);
            requestBody.put("boost", 100.0);
            requestBody.put("available", true);
            requestBody.put("sort_order", 1);
    Java
    - Registered: Mon May 06 08:04:11 GMT 2024
    - Last Modified: Thu Feb 22 01:37:57 GMT 2024
    - 3.9K bytes
    - Viewed (0)
  9. src/test/java/jcifs/tests/WatchTest.java

        private void setupWatch ( SmbWatchHandle w ) throws InterruptedException {
            if ( this.future != null ) {
                this.future.cancel(true);
            }
            this.future = this.executor.submit(w);
            Thread.sleep(1000);
        }
    
    
        @Test
        public void testWatchCreate () throws CIFSException, MalformedURLException, UnknownHostException, InterruptedException, ExecutionException {
    Java
    - Registered: Sun May 05 00:10:10 GMT 2024
    - Last Modified: Sun Jul 01 13:12:10 GMT 2018
    - 8.4K bytes
    - Viewed (0)
  10. src/test/java/org/codelibs/core/timer/TimeoutManagerTest.java

                }
            }, 1, true);
    
            assertNotNull(TimeoutManager.getInstance().thread);
            Thread.sleep(2000);
            assertTrue(expiredCount > 0);
            assertEquals(1, TimeoutManager.getInstance().getTimeoutTaskCount());
            TimeoutManager.getInstance().stop();
            assertNull(TimeoutManager.getInstance().thread);
            Thread.sleep(10);
            int count = expiredCount;
            task.stop();
    Java
    - Registered: Fri May 03 20:58:11 GMT 2024
    - Last Modified: Thu Mar 07 01:59:08 GMT 2024
    - 2.1K bytes
    - Viewed (0)
Back to top