Searched refs:ThreadPool (Results 1 – 12 of 12) sorted by relevance
| /libcore/ojluni/src/main/java/sun/nio/ch/ |
| D | ThreadPool.java | 37 public class ThreadPool { class
52 private ThreadPool(ExecutorService executor, in ThreadPool() method in ThreadPool
102 final static ThreadPool defaultThreadPool = createDefault();
106 static ThreadPool getDefault() { in getDefault()
111 static ThreadPool createDefault() { in createDefault()
122 return new ThreadPool(executor, false, initialSize); in createDefault()
126 static ThreadPool create(int nThreads, ThreadFactory factory) { in create()
130 return new ThreadPool(executor, true, nThreads); in create()
134 public static ThreadPool wrap(ExecutorService executor, int initialSize) { in wrap()
153 return new ThreadPool(executor, false, initialSize); in wrap()
|
| D | LinuxAsynchronousChannelProvider.java | 43 defaultPort = new EPollPort(this, ThreadPool.getDefault()).start(); in defaultEventPort()
57 return new EPollPort(this, ThreadPool.create(nThreads, factory)).start(); in openAsynchronousChannelGroup()
64 return new EPollPort(this, ThreadPool.wrap(executor, initialSize)).start(); in openAsynchronousChannelGroup()
|
| D | AsynchronousChannelGroupImpl.java | 55 private final ThreadPool pool;
73 ThreadPool pool) in AsynchronousChannelGroupImpl()
87 Executors.newScheduledThreadPool(1, ThreadPool.defaultThreadFactory()); in AsynchronousChannelGroupImpl()
123 ThreadPool.defaultThreadFactory().newThread(task).start();
|
| D | Port.java | 57 Port(AsynchronousChannelProvider provider, ThreadPool pool) { in Port()
|
| D | SimpleAsynchronousFileChannelImpl.java | 47 ThreadPool.createDefault().executor();
68 ThreadPool pool) in open()
|
| D | EPollPort.java | 83 EPollPort(AsynchronousChannelProvider provider, ThreadPool pool) in EPollPort()
|
| /libcore/luni/src/test/java/tests/support/ |
| D | ThreadPool.java | 22 public class ThreadPool extends ThreadGroup { class
32 public ThreadPool(int numThreads) { in ThreadPool() method in ThreadPool
93 super(ThreadPool.this, "PooledThread-" + (threadID++)); in PooledThread()
|
| /libcore/luni/src/test/java/tests/java/sql/ |
| D | StressTest.java | 32 import tests.support.ThreadPool;
126 ThreadPool threadPool = new ThreadPool(numTasks); in testManyConnectionsUsingManyThreads()
199 ThreadPool threadPool = new ThreadPool(numConnections); in testInsertOfManyRowsUsingManyThreads()
|
| D | MultiThreadAccessTest.java | 33 import tests.support.ThreadPool;
45 private ThreadPool threadPool;
57 threadPool = new ThreadPool(numThreads); in setUp()
|
| /libcore/ojluni/src/main/java/sun/nio/fs/ |
| D | UnixChannelFactory.java | 34 import sun.nio.ch.ThreadPool;
157 ThreadPool pool) in newAsynchronousFileChannel()
|
| D | UnixFileSystemProvider.java | 39 import sun.nio.ch.ThreadPool;
191 ThreadPool pool = (executor == null) ? null : ThreadPool.wrap(executor, 0); in newAsynchronousFileChannel()
|
| /libcore/ |
| D | openjdk_java_files.bp | 1582 "ojluni/src/main/java/sun/nio/ch/ThreadPool.java",
|