Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 19 for interrupt (0.16 sec)

  1. src/main/java/org/codelibs/fess/helper/ProcessHelper.java

            if (jobProcess != null) {
                final InputStreamThread ist = jobProcess.getInputStreamThread();
                try {
                    ist.interrupt();
                } catch (final Exception e) {
                    logger.warn("Could not interrupt a thread of an input stream.", e);
                }
    
                final CountDownLatch latch = new CountDownLatch(3);
                final Process process = jobProcess.getProcess();
    Java
    - Registered: Mon May 06 08:04:11 GMT 2024
    - Last Modified: Thu Feb 22 01:37:57 GMT 2024
    - 6.4K bytes
    - Viewed (0)
  2. src/main/java/jcifs/netbios/NameServiceClientImpl.java

            joinThread(q1x);
            interruptThreadSafely(q20);
            joinThread(q20);
        }
    
    
        private static void interruptThreadSafely ( QueryThread thread ) {
            try {
                thread.interrupt();
            }
            catch ( SecurityException e ) {
                e.printStackTrace();
            }
        }
    
    
        private static void joinThread ( Thread thread ) {
            try {
    Java
    - Registered: Sun May 05 00:10:10 GMT 2024
    - Last Modified: Sun Aug 14 14:26:22 GMT 2022
    - 38.2K bytes
    - Viewed (0)
  3. src/main/java/org/codelibs/fess/ds/callback/FileListIndexUpdateCallbackImpl.java

                executor.awaitTermination(executorTerminationTimeout, TimeUnit.SECONDS);
            } catch (final InterruptedException e) {
                if (logger.isDebugEnabled()) {
                    logger.debug("Failed to interrupt executor.", e);
                }
            } finally {
                executor.shutdownNow();
            }
    
            if (!deleteUrlList.isEmpty()) {
                deleteDocuments();
            }
    Java
    - Registered: Mon May 06 08:04:11 GMT 2024
    - Last Modified: Thu Feb 22 01:37:57 GMT 2024
    - 16.8K bytes
    - Viewed (0)
  4. src/main/java/org/codelibs/fess/exec/Crawler.java

                exitCode = Constants.EXIT_FAIL;
            } finally {
                if (commandThread != null && commandThread.isAlive()) {
                    commandThread.interrupt();
                }
                if (systemMonitorTask != null) {
                    systemMonitorTask.cancel();
                }
                if (hotThreadMonitorTask != null) {
                    hotThreadMonitorTask.cancel();
    Java
    - Registered: Mon May 06 08:04:11 GMT 2024
    - Last Modified: Thu Feb 22 01:37:57 GMT 2024
    - 24.1K bytes
    - Viewed (2)
  5. src/main/java/org/codelibs/core/timer/TimeoutManager.java

                }
            }
        }
    
        /**
         * 処理を停止します。
         */
        public synchronized void stop() {
            if (thread != null) {
                thread.interrupt();
                thread = null;
                if (logger.isDebugEnabled()) {
                    logger.debug("TimeoutManager stopped.");
                }
            }
        }
    
        /**
         * スレッドに割り込みを行い、終了するまで待機します。
    Java
    - Registered: Fri May 03 20:58:11 GMT 2024
    - Last Modified: Thu Mar 07 01:59:08 GMT 2024
    - 8K bytes
    - Viewed (0)
  6. src/main/java/org/codelibs/fess/helper/DataIndexHelper.java

                        logger.debug("Interrupted.", e);
                    }
                }
            }
    
            public void awaitTermination(final long mills) {
                try {
                    join(mills);
                } catch (final InterruptedException e) {
                    if (logger.isDebugEnabled()) {
                        logger.debug("Interrupted.", e);
                    }
                }
            }
    Java
    - Registered: Mon May 06 08:04:11 GMT 2024
    - Last Modified: Thu Feb 22 01:37:57 GMT 2024
    - 12K bytes
    - Viewed (0)
  7. src/main/java/org/codelibs/fess/exec/ThumbnailGenerator.java

                executorService.awaitTermination(60, TimeUnit.SECONDS);
            } catch (final InterruptedException e) {
                if (logger.isDebugEnabled()) {
                    logger.debug("Interrupted.", e);
                }
            } finally {
                executorService.shutdownNow();
            }
            return totalCount;
        }
    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)
  8. src/main/java/jcifs/util/transport/Transport.java

            Thread t = this.thread;
            if ( t != null && Thread.currentThread() != t ) {
                this.thread = null;
                try {
                    log.debug("Interrupting transport thread");
                    t.interrupt();
                    log.debug("Joining transport thread");
                    t.join(timeout);
                    log.debug("Joined transport thread");
                }
                catch ( InterruptedException e ) {
    Java
    - Registered: Sun May 05 00:10:10 GMT 2024
    - Last Modified: Sun Nov 01 18:12:21 GMT 2020
    - 24.1K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/fess/thumbnail/ThumbnailManager.java

                }
            }, "ThumbnailGenerator");
            thumbnailQueueThread.start();
        }
    
        @PreDestroy
        public void destroy() {
            generating = false;
            thumbnailQueueThread.interrupt();
            try {
                thumbnailQueueThread.join(10000);
            } catch (final InterruptedException e) {
                logger.warn("Thumbnail thread is timeouted.", e);
            }
    Java
    - Registered: Mon May 06 08:04:11 GMT 2024
    - Last Modified: Thu Feb 22 01:37:57 GMT 2024
    - 21.5K bytes
    - Viewed (0)
  10. src/test/java/jcifs/tests/ConcurrencyTest.java

                    try {
                        synchronized ( lock ) {
                            lock.wait(1000);
                        }
    
                        Thread.sleep(100);
                        t.interrupt();
                    }
                    catch ( InterruptedException e ) {
                        e.printStackTrace();
                    }
                }
            });
    
            try {
    Java
    - Registered: Sun May 05 00:10:10 GMT 2024
    - Last Modified: Sun Nov 14 17:40:50 GMT 2021
    - 17.6K bytes
    - Viewed (0)
Back to top