58 |
|
return new DelegatedExecutorService |
59 |
|
(new ThreadPoolExecutor(nThreads, nThreads, |
60 |
|
0L, TimeUnit.MILLISECONDS, |
61 |
< |
new LinkedBlockingQueue())); |
61 |
> |
new LinkedBlockingQueue<Runnable>())); |
62 |
|
} |
63 |
|
|
64 |
|
/** |
74 |
|
return new DelegatedExecutorService |
75 |
|
(new ThreadPoolExecutor(nThreads, nThreads, |
76 |
|
0L, TimeUnit.MILLISECONDS, |
77 |
< |
new LinkedBlockingQueue(), |
77 |
> |
new LinkedBlockingQueue<Runnable>(), |
78 |
|
threadFactory, null)); |
79 |
|
} |
80 |
|
|
93 |
|
return new DelegatedExecutorService |
94 |
|
(new ThreadPoolExecutor(1, 1, |
95 |
|
0L, TimeUnit.MILLISECONDS, |
96 |
< |
new LinkedBlockingQueue())); |
96 |
> |
new LinkedBlockingQueue<Runnable>())); |
97 |
|
} |
98 |
|
|
99 |
|
/** |
109 |
|
return new DelegatedExecutorService |
110 |
|
(new ThreadPoolExecutor(1, 1, |
111 |
|
0L, TimeUnit.MILLISECONDS, |
112 |
< |
new LinkedBlockingQueue(), |
112 |
> |
new LinkedBlockingQueue<Runnable>(), |
113 |
|
threadFactory, null)); |
114 |
|
} |
115 |
|
|
131 |
|
return new DelegatedExecutorService |
132 |
|
(new ThreadPoolExecutor(0, Integer.MAX_VALUE, |
133 |
|
60, TimeUnit.SECONDS, |
134 |
< |
new SynchronousQueue())); |
134 |
> |
new SynchronousQueue<Runnable>())); |
135 |
|
} |
136 |
|
|
137 |
|
/** |
146 |
|
return new DelegatedExecutorService |
147 |
|
(new ThreadPoolExecutor(0, Integer.MAX_VALUE, |
148 |
|
60, TimeUnit.SECONDS, |
149 |
< |
new SynchronousQueue(), |
149 |
> |
new SynchronousQueue<Runnable>(), |
150 |
|
threadFactory, null)); |
151 |
|
} |
152 |
|
|