Search Options

Results per page
Sort
Preferred Languages
Advance

Results 21 - 28 of 28 for setDaemon (0.25 sec)

  1. android/guava-tests/benchmark/com/google/common/collect/ConcurrentHashMultisetBenchmark.java

        for (int i = 0; i < size; i++) {
          builder.add(i);
        }
        keys = builder.build();
        threadPool =
            Executors.newFixedThreadPool(threads, new ThreadFactoryBuilder().setDaemon(true).build());
      }
    
      @Benchmark
      long add(final int reps) throws ExecutionException, InterruptedException {
        return doMultithreadedLoop(
            new Callable<Long>() {
              @Override
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Thu Apr 06 12:56:11 GMT 2023
    - 16.6K bytes
    - Viewed (0)
  2. android/guava-tests/test/com/google/common/util/concurrent/UninterruptiblesTest.java

                } catch (InterruptedException e) {
                  // simply finish execution
                } finally {
                  lock.unlock();
                }
              }
            };
        thread.setDaemon(true);
        thread.start();
        awaitUninterruptibly(latch);
        return thread;
      }
    
      private static class TestCondition implements Condition {
        private final Lock lock;
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Wed Feb 09 22:57:07 GMT 2022
    - 30.9K bytes
    - Viewed (0)
  3. src/main/java/jcifs/util/transport/Transport.java

                    log.debug("Connecting " + this.name);
                }
    
                this.state = 1;
                this.te = null;
    
                Thread t = new Thread(this, this.name);
                t.setDaemon(true);
                this.thread = t;
    
                synchronized ( this.thread ) {
                    t.start();
                    t.wait(timeout); /* wait for doConnect */
    
                    st = this.state;
    Java
    - Registered: Sun Apr 28 00:10:09 GMT 2024
    - Last Modified: Sun Nov 01 18:12:21 GMT 2020
    - 24.1K bytes
    - Viewed (0)
  4. android/guava/src/com/google/common/util/concurrent/MoreExecutors.java

      }
    
      @J2ktIncompatible
      @GwtIncompatible // TODO
      private static void useDaemonThreadFactory(ThreadPoolExecutor executor) {
        executor.setThreadFactory(
            new ThreadFactoryBuilder()
                .setDaemon(true)
                .setThreadFactory(executor.getThreadFactory())
                .build());
      }
    
      // See newDirectExecutorService javadoc for behavioral notes.
      @J2ktIncompatible
      @GwtIncompatible // TODO
    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)
  5. guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java

      }
    
      /** Returns a new started daemon Thread running the given runnable. */
      Thread newStartedThread(Runnable runnable) {
        Thread t = new Thread(runnable);
        t.setDaemon(true);
        t.start();
        return t;
      }
    
      /**
       * Waits for the specified time (in milliseconds) for the thread to terminate (using {@link
    Java
    - Registered: Fri Apr 12 12:43:09 GMT 2024
    - Last Modified: Thu Feb 22 17:15:24 GMT 2024
    - 37.7K bytes
    - Viewed (0)
  6. android/guava-tests/test/com/google/common/util/concurrent/JSR166TestCase.java

      }
    
      /** Returns a new started daemon Thread running the given runnable. */
      Thread newStartedThread(Runnable runnable) {
        Thread t = new Thread(runnable);
        t.setDaemon(true);
        t.start();
        return t;
      }
    
      /**
       * Waits for the specified time (in milliseconds) for the thread to terminate (using {@link
    Java
    - Registered: Fri Apr 26 12:43:10 GMT 2024
    - Last Modified: Thu Feb 22 17:15:24 GMT 2024
    - 37.2K bytes
    - Viewed (0)
  7. src/main/java/jcifs/smb/SmbFile.java

                    throw new SmbException("Source and destination paths overlap.");
                }
    
                WriterThread w = new WriterThread();
                w.setDaemon(true);
    
                try {
                    w.start();
                    // use commonly acceptable buffer size
                    int bsize = Math.min(sh.getReceiveBufferSize() - 70, dh.getSendBufferSize() - 70);
    Java
    - Registered: Sun Apr 28 00:10:09 GMT 2024
    - Last Modified: Mon Mar 13 12:00:57 GMT 2023
    - 81.6K bytes
    - Viewed (0)
  8. src/main/java/jcifs/smb1/smb1/SmbFile.java

                    throw new SmbException( "Source and destination paths overlap." );
                }
            } catch (UnknownHostException uhe) {
            }
    
            w = new WriterThread();
            w.setDaemon( true );
            w.start();
    
            /* Downgrade one transport to the lower of the negotiated buffer sizes
             * so we can just send whatever is received.
             */
    
    Java
    - Registered: Sun Apr 28 00:10:09 GMT 2024
    - Last Modified: Mon Mar 13 12:00:57 GMT 2023
    - 107.9K bytes
    - Viewed (2)
Back to top