- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 46 for Command (0.2 sec)
-
src/main/java/org/codelibs/fess/auth/chain/CommandChain.java
protected int executeCommand(final String[] commands, final String username, final String password) { if (commands == null || commands.length == 0) { throw new CommandExecutionException("command is empty."); } if (logger.isInfoEnabled()) { logger.info("Command: {}", String.join(" ", commands)); } final String[] cmds = stream(commands).get(stream -> stream.map(s -> {
Java - Registered: Mon Apr 29 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 9.3K bytes - Viewed (0) -
guava-gwt/src-super/com/google/common/util/concurrent/super/com/google/common/util/concurrent/AbstractFuture.java
} } private static final class Listener { final Runnable command; final Executor executor; Listener(Runnable command, Executor executor) { this.command = checkNotNull(command); this.executor = checkNotNull(executor); } void execute() { try { executor.execute(command); } catch (RuntimeException e) { log.log( Level.SEVERE,
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Mon Jan 22 19:37:41 GMT 2024 - 12.3K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/MoreExecutors.java
@GuardedBy("lock") private int runningTasks = 0; @GuardedBy("lock") private boolean shutdown = false; @Override public void execute(Runnable command) { startTask(); try { command.run(); } finally { endTask(); } } @Override public boolean isShutdown() { synchronized (lock) { return shutdown;
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Apr 17 16:33:44 GMT 2024 - 41.8K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/AbstractScheduledServiceTest.java
new ScheduledThreadPoolExecutor(10) { @Override public ScheduledFuture<?> scheduleWithFixedDelay( Runnable command, long initialDelay, long delay, TimeUnit unit) { return future = super.scheduleWithFixedDelay(command, initialDelay, delay, unit); } }; public void testServiceStartStop() throws Exception { NullService service = new NullService();
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 22.5K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/AbstractScheduledServiceTest.java
new ScheduledThreadPoolExecutor(10) { @Override public ScheduledFuture<?> scheduleWithFixedDelay( Runnable command, long initialDelay, long delay, TimeUnit unit) { return future = super.scheduleWithFixedDelay(command, initialDelay, delay, unit); } }; public void testServiceStartStop() throws Exception { NullService service = new NullService();
Java - Registered: Fri Apr 12 12:43:09 GMT 2024 - Last Modified: Wed Sep 06 17:04:31 GMT 2023 - 22.5K bytes - Viewed (0) -
android/guava-testlib/src/com/google/common/util/concurrent/testing/TestingExecutors.java
} @Override public ListenableScheduledFuture<?> schedule(Runnable command, long delay, TimeUnit unit) { return NeverScheduledFuture.create(); } @Override public ListenableScheduledFuture<?> scheduleAtFixedRate( Runnable command, long initialDelay, long period, TimeUnit unit) { return NeverScheduledFuture.create(); } @Override
Java - Registered: Fri Apr 26 12:43:10 GMT 2024 - Last Modified: Fri May 26 22:04:00 GMT 2023 - 6.7K bytes - Viewed (0) -
guava-testlib/src/com/google/common/util/concurrent/testing/TestingExecutors.java
} @Override public ListenableScheduledFuture<?> schedule(Runnable command, long delay, TimeUnit unit) { return NeverScheduledFuture.create(); } @Override public ListenableScheduledFuture<?> scheduleAtFixedRate( Runnable command, long initialDelay, long period, TimeUnit unit) { return NeverScheduledFuture.create(); } @Override
Java - Registered: Fri Apr 19 12:43:09 GMT 2024 - Last Modified: Fri May 26 22:04:00 GMT 2023 - 6.7K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/thumbnail/impl/CommandGenerator.java
final String commandTimeoutStr = fessConfig.getSystemProperty("thumbnail.command.timeout"); if (commandTimeoutStr != null) { commandTimeout = Long.valueOf(commandTimeoutStr); } final String commandDestroyTimeoutStr = fessConfig.getSystemProperty("thumbnail.command.destroy.timeout"); if (commandDestroyTimeoutStr != null) {
Java - Registered: Mon Apr 29 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 9.6K bytes - Viewed (0) -
build-logic/cleanup/src/main/java/gradlebuild/cleanup/services/KillLeakingJavaProcesses.java
import java.util.regex.Pattern; import java.util.stream.Collectors; import java.util.stream.Stream; import static java.util.regex.Pattern.quote; /** * NOTICE: this class is invoked via java command line, so we must NOT DEPEND ON ANY 3RD-PARTY LIBRARIES except JDK 11. * * Usage: java build-logic/cleanup/src/main/java/gradlebuild/cleanup/services/KillLeakingJavaProcesses.java */ public class KillLeakingJavaProcesses {
Java - Registered: Wed May 01 11:36:15 GMT 2024 - Last Modified: Fri Apr 26 09:46:00 GMT 2024 - 11.3K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/ProcessHelper.java
final JobProcess jobProcess = runningProcessMap.get(sessionId); if (jobProcess == null) { throw new JobNotFoundException("Job for " + sessionId + " is not found."); } try { final OutputStream out = jobProcess.getProcess().getOutputStream(); IOUtils.write(command + "\n", out, Constants.CHARSET_UTF_8);
Java - Registered: Mon Apr 29 08:04:11 GMT 2024 - Last Modified: Thu Feb 22 01:37:57 GMT 2024 - 6.4K bytes - Viewed (0)