Home
last modified time | relevance | path

Searched refs:cleaner (Results 1 – 25 of 64) sorted by relevance

123

/libcore/jsr166-tests/src/test/java/jsr166/
DForkJoinPoolTest.java171 try (PoolCleaner cleaner = cleaner(p)) { in testDefaultInitialState() argument
211 try (PoolCleaner cleaner = cleaner(p)) { in testGetParallelism() argument
223 try (PoolCleaner cleaner = cleaner(p)) { in testGetPoolSize() argument
247 try (PoolCleaner cleaner = cleaner(p)) { in testAwaitTermination_timesOut() argument
288 try (PoolCleaner cleaner = cleaner(p)) { in testSetUncaughtExceptionHandler() argument
307 try (PoolCleaner cleaner = cleaner(p)) { in testIsQuiescent() argument
346 try (PoolCleaner cleaner = cleaner(p)) {
357 try (PoolCleaner cleaner = cleaner(p)) {
389 try (PoolCleaner cleaner = cleaner(p)) {
406 try (PoolCleaner cleaner = cleaner(p)) {
[all …]
DThreadPoolExecutorTest.java95 try (PoolCleaner cleaner = cleaner(p)) { in testExecute() argument
114 try (PoolCleaner cleaner = cleaner(p, done)) { in testGetActiveCount() argument
136 try (PoolCleaner cleaner = cleaner(p)) { in testPrestartCoreThread() argument
162 try (PoolCleaner cleaner = cleaner(p)) { in testPrestartAllCoreThreads() argument
185 try (PoolCleaner cleaner = cleaner(p)) { in testGetCompletedTaskCount() argument
218 try (PoolCleaner cleaner = cleaner(p)) { in testGetCorePoolSize() argument
231 try (PoolCleaner cleaner = cleaner(p)) { in testGetKeepAliveTime() argument
247 try (PoolCleaner cleaner = cleaner(p)) { in testGetThreadFactory() argument
260 try (PoolCleaner cleaner = cleaner(p)) { in testSetThreadFactory() argument
275 try (PoolCleaner cleaner = cleaner(p)) { in testSetThreadFactoryNull() argument
[all …]
DScheduledExecutorSubclassTest.java111 try (PoolCleaner cleaner = cleaner(p)) { in testExecute() argument
126 try (PoolCleaner cleaner = cleaner(p, done)) { in testSchedule1() argument
145 try (PoolCleaner cleaner = cleaner(p)) { in testSchedule3() argument
165 try (PoolCleaner cleaner = cleaner(p)) { in testSchedule4() argument
187 try (PoolCleaner cleaner = cleaner(p)) { in testSchedule5() argument
216 try (PoolCleaner cleaner = cleaner(p)) { in testFixedRateSequence() argument
245 try (PoolCleaner cleaner = cleaner(p)) { in testFixedDelaySequence() argument
289 try (PoolCleaner cleaner = cleaner(p)) { in testExecuteNull() argument
302 try (PoolCleaner cleaner = cleaner(p)) { in testScheduleNull() argument
316 try (PoolCleaner cleaner = cleaner(p)) { in testSchedule1_RejectedExecutionException() argument
[all …]
DScheduledExecutorTest.java54 try (PoolCleaner cleaner = cleaner(p)) { in testExecute() argument
68 try (PoolCleaner cleaner = cleaner(p)) { in testSchedule1() argument
89 try (PoolCleaner cleaner = cleaner(p)) { in testSchedule3() argument
109 try (PoolCleaner cleaner = cleaner(p)) { in testSchedule4() argument
131 try (PoolCleaner cleaner = cleaner(p)) { in testSchedule5() argument
160 try (PoolCleaner cleaner = cleaner(p)) { in testFixedRateSequence() argument
189 try (PoolCleaner cleaner = cleaner(p)) { in testFixedDelaySequence() argument
233 try (PoolCleaner cleaner = cleaner(p)) { in testExecuteNull() argument
246 try (PoolCleaner cleaner = cleaner(p)) { in testScheduleNull() argument
260 try (PoolCleaner cleaner = cleaner(p)) { in testSchedule1_RejectedExecutionException() argument
[all …]
DThreadPoolExecutorSubclassTest.java242 try (PoolCleaner cleaner = cleaner(p)) { in testExecute() argument
261 try (PoolCleaner cleaner = cleaner(p, done)) { in testGetActiveCount() argument
283 try (PoolCleaner cleaner = cleaner(p)) { in testPrestartCoreThread() argument
309 try (PoolCleaner cleaner = cleaner(p)) { in testPrestartAllCoreThreads() argument
332 try (PoolCleaner cleaner = cleaner(p)) { in testGetCompletedTaskCount() argument
365 try (PoolCleaner cleaner = cleaner(p)) { in testGetCorePoolSize() argument
378 try (PoolCleaner cleaner = cleaner(p)) { in testGetKeepAliveTime() argument
394 try (PoolCleaner cleaner = cleaner(p)) { in testGetThreadFactory() argument
407 try (PoolCleaner cleaner = cleaner(p)) { in testSetThreadFactory() argument
422 try (PoolCleaner cleaner = cleaner(p)) { in testSetThreadFactoryNull() argument
[all …]
DAbstractExecutorServiceTest.java208 try (PoolCleaner cleaner = cleaner(p, quittingTime)) { in testInterruptedSubmit() argument
231 try (PoolCleaner cleaner = cleaner(p)) { in testSubmitEE() argument
248 try (PoolCleaner cleaner = cleaner(e)) { in testInvokeAny1() argument
261 try (PoolCleaner cleaner = cleaner(e)) { in testInvokeAny2() argument
274 try (PoolCleaner cleaner = cleaner(e)) { in testInvokeAny3() argument
291 try (PoolCleaner cleaner = cleaner(e)) { in testInvokeAny4() argument
308 try (PoolCleaner cleaner = cleaner(e)) { in testInvokeAny5() argument
322 try (PoolCleaner cleaner = cleaner(e)) { in testInvokeAll1() argument
335 try (PoolCleaner cleaner = cleaner(e)) { in testInvokeAll2() argument
346 try (PoolCleaner cleaner = cleaner(e)) { in testInvokeAll3() argument
[all …]
DExecutorCompletionServiceTest.java66 try (PoolCleaner cleaner = cleaner(e)) { in testSubmitNPE() argument
81 try (PoolCleaner cleaner = cleaner(e)) { in testSubmitNPE2() argument
96 try (PoolCleaner cleaner = cleaner(e)) { in testTake() argument
110 try (PoolCleaner cleaner = cleaner(e)) { in testTake2() argument
124 try (PoolCleaner cleaner = cleaner(e)) { in testPoll1() argument
147 try (PoolCleaner cleaner = cleaner(e)) { in testPoll2() argument
176 try (PoolCleaner cleaner = cleaner(e)) { in testNewTaskForCallable() argument
207 try (PoolCleaner cleaner = cleaner(e)) { in testNewTaskForRunnable() argument
DExecutorsTest.java47 try (PoolCleaner cleaner = cleaner(e)) { in testNewCachedThreadPool1() argument
59 try (PoolCleaner cleaner = cleaner(e)) { in testNewCachedThreadPool2() argument
81 try (PoolCleaner cleaner = cleaner(e)) { in testNewSingleThreadExecutor1() argument
93 try (PoolCleaner cleaner = cleaner(e)) { in testNewSingleThreadExecutor2() argument
115 try (PoolCleaner cleaner = cleaner(e)) { in testCastNewSingleThreadExecutor() argument
128 try (PoolCleaner cleaner = cleaner(e)) { in testNewFixedThreadPool1() argument
140 try (PoolCleaner cleaner = cleaner(e)) { in testNewFixedThreadPool2() argument
172 try (PoolCleaner cleaner = cleaner(e)) { in testUnconfigurableExecutorService() argument
204 try (PoolCleaner cleaner = cleaner(p)) { in testNewSingleThreadScheduledExecutor() argument
228 try (PoolCleaner cleaner = cleaner(p)) { in testNewScheduledThreadPool() argument
[all …]
/libcore/ojluni/src/test/java/util/concurrent/tck/
DForkJoinPoolTest.java189 try (PoolCleaner cleaner = cleaner(p)) { in testDefaultInitialState() argument
229 try (PoolCleaner cleaner = cleaner(p)) { in testGetParallelism() argument
241 try (PoolCleaner cleaner = cleaner(p)) { in testGetPoolSize() argument
265 try (PoolCleaner cleaner = cleaner(p)) { in testAwaitTermination_timesOut() argument
306 try (PoolCleaner cleaner = cleaner(p)) { in testSetUncaughtExceptionHandler() argument
325 try (PoolCleaner cleaner = cleaner(p)) { in testIsQuiescent() argument
364 try (PoolCleaner cleaner = cleaner(p)) {
375 try (PoolCleaner cleaner = cleaner(p)) {
407 try (PoolCleaner cleaner = cleaner(p)) {
424 try (PoolCleaner cleaner = cleaner(p)) {
[all …]
DThreadPoolExecutorTest.java117 try (PoolCleaner cleaner = cleaner(p)) { in testExecute() argument
136 try (PoolCleaner cleaner = cleaner(p, done)) { in testGetActiveCount() argument
158 try (PoolCleaner cleaner = cleaner(p)) { in testPrestartCoreThread() argument
184 try (PoolCleaner cleaner = cleaner(p)) { in testPrestartAllCoreThreads() argument
207 try (PoolCleaner cleaner = cleaner(p)) { in testGetCompletedTaskCount() argument
240 try (PoolCleaner cleaner = cleaner(p)) { in testGetCorePoolSize() argument
253 try (PoolCleaner cleaner = cleaner(p)) { in testGetKeepAliveTime() argument
269 try (PoolCleaner cleaner = cleaner(p)) { in testGetThreadFactory() argument
282 try (PoolCleaner cleaner = cleaner(p)) { in testSetThreadFactory() argument
297 try (PoolCleaner cleaner = cleaner(p)) { in testSetThreadFactoryNull() argument
[all …]
DScheduledExecutorTest.java76 try (PoolCleaner cleaner = cleaner(p)) { in testExecute() argument
90 try (PoolCleaner cleaner = cleaner(p)) { in testSchedule1() argument
111 try (PoolCleaner cleaner = cleaner(p)) { in testSchedule3() argument
131 try (PoolCleaner cleaner = cleaner(p)) { in testSchedule4() argument
153 try (PoolCleaner cleaner = cleaner(p)) { in testSchedule5() argument
182 try (PoolCleaner cleaner = cleaner(p)) { in testFixedRateSequence() argument
211 try (PoolCleaner cleaner = cleaner(p)) { in testFixedDelaySequence() argument
255 try (PoolCleaner cleaner = cleaner(p)) { in testExecuteNull() argument
268 try (PoolCleaner cleaner = cleaner(p)) { in testScheduleNull() argument
282 try (PoolCleaner cleaner = cleaner(p)) { in testSchedule1_RejectedExecutionException() argument
[all …]
DScheduledExecutorSubclassTest.java133 try (PoolCleaner cleaner = cleaner(p)) { in testExecute() argument
148 try (PoolCleaner cleaner = cleaner(p, done)) { in testSchedule1() argument
167 try (PoolCleaner cleaner = cleaner(p)) { in testSchedule3() argument
187 try (PoolCleaner cleaner = cleaner(p)) { in testSchedule4() argument
209 try (PoolCleaner cleaner = cleaner(p)) { in testSchedule5() argument
238 try (PoolCleaner cleaner = cleaner(p)) { in testFixedRateSequence() argument
267 try (PoolCleaner cleaner = cleaner(p)) { in testFixedDelaySequence() argument
311 try (PoolCleaner cleaner = cleaner(p)) { in testExecuteNull() argument
324 try (PoolCleaner cleaner = cleaner(p)) { in testScheduleNull() argument
338 try (PoolCleaner cleaner = cleaner(p)) { in testSchedule1_RejectedExecutionException() argument
[all …]
DThreadPoolExecutorSubclassTest.java264 try (PoolCleaner cleaner = cleaner(p)) { in testExecute() argument
283 try (PoolCleaner cleaner = cleaner(p, done)) { in testGetActiveCount() argument
305 try (PoolCleaner cleaner = cleaner(p)) { in testPrestartCoreThread() argument
331 try (PoolCleaner cleaner = cleaner(p)) { in testPrestartAllCoreThreads() argument
354 try (PoolCleaner cleaner = cleaner(p)) { in testGetCompletedTaskCount() argument
387 try (PoolCleaner cleaner = cleaner(p)) { in testGetCorePoolSize() argument
400 try (PoolCleaner cleaner = cleaner(p)) { in testGetKeepAliveTime() argument
416 try (PoolCleaner cleaner = cleaner(p)) { in testGetThreadFactory() argument
429 try (PoolCleaner cleaner = cleaner(p)) { in testSetThreadFactory() argument
444 try (PoolCleaner cleaner = cleaner(p)) { in testSetThreadFactoryNull() argument
[all …]
DAbstractExecutorServiceTest.java231 try (PoolCleaner cleaner = cleaner(p, quittingTime)) { in testInterruptedSubmit() argument
254 try (PoolCleaner cleaner = cleaner(p)) { in testSubmitEE() argument
271 try (PoolCleaner cleaner = cleaner(e)) { in testInvokeAny1() argument
284 try (PoolCleaner cleaner = cleaner(e)) { in testInvokeAny2() argument
297 try (PoolCleaner cleaner = cleaner(e)) { in testInvokeAny3() argument
314 try (PoolCleaner cleaner = cleaner(e)) { in testInvokeAny4() argument
331 try (PoolCleaner cleaner = cleaner(e)) { in testInvokeAny5() argument
345 try (PoolCleaner cleaner = cleaner(e)) { in testInvokeAll1() argument
358 try (PoolCleaner cleaner = cleaner(e)) { in testInvokeAll2() argument
369 try (PoolCleaner cleaner = cleaner(e)) { in testInvokeAll3() argument
[all …]
DExecutorsTest.java70 try (PoolCleaner cleaner = cleaner(e)) { in testNewCachedThreadPool1() argument
82 try (PoolCleaner cleaner = cleaner(e)) { in testNewCachedThreadPool2() argument
104 try (PoolCleaner cleaner = cleaner(e)) { in testNewSingleThreadExecutor1() argument
116 try (PoolCleaner cleaner = cleaner(e)) { in testNewSingleThreadExecutor2() argument
138 try (PoolCleaner cleaner = cleaner(e)) { in testCastNewSingleThreadExecutor() argument
151 try (PoolCleaner cleaner = cleaner(e)) { in testNewFixedThreadPool1() argument
163 try (PoolCleaner cleaner = cleaner(e)) { in testNewFixedThreadPool2() argument
195 try (PoolCleaner cleaner = cleaner(e)) { in testUnconfigurableExecutorService() argument
227 try (PoolCleaner cleaner = cleaner(p)) { in testNewSingleThreadScheduledExecutor() argument
251 try (PoolCleaner cleaner = cleaner(p)) { in testNewScheduledThreadPool() argument
[all …]
DExecutorCompletionServiceTest.java236 try (PoolCleaner cleaner = cleaner(e)) { in testNewTaskForCallable() argument
266 try (PoolCleaner cleaner = cleaner(e)) { in testNewTaskForRunnable() argument
/libcore/ojluni/src/main/java/sun/nio/fs/
DNativeBuffer.java40 private final Cleaner cleaner; field in NativeBuffer
59 this.cleaner = Cleaner.create(this, new Deallocator(address)); in NativeBuffer()
80 Cleaner cleaner() { in cleaner() method in NativeBuffer
81 return cleaner; in cleaner()
DNativeBuffers.java110 existing.cleaner().clean(); in releaseNativeBuffer()
117 buffer.cleaner().clean(); in releaseNativeBuffer()
/libcore/luni/src/main/java/libcore/util/
DNativeAllocationRegistry.java268 Cleaner cleaner = Cleaner.create(referent, thunk); in registerNativeAllocation() local
269 result = new CleanerRunner(cleaner); in registerNativeAllocation()
302 private final Cleaner cleaner; field in NativeAllocationRegistry.CleanerRunner
304 public CleanerRunner(Cleaner cleaner) { in CleanerRunner() argument
305 this.cleaner = cleaner; in CleanerRunner()
309 cleaner.clean(); in run()
/libcore/luni/src/test/java/libcore/java/util/concurrent/
DForkJoinTaskTest.java44 try (ExecutorServiceAutoCloseable cleaner = new ExecutorServiceAutoCloseable(pool)) { in testAdaptToRunnableWithResult() argument
63 try (ExecutorServiceAutoCloseable cleaner = new ExecutorServiceAutoCloseable(pool)) { in testAdaptToCallable() argument
82 try (ExecutorServiceAutoCloseable cleaner = new ExecutorServiceAutoCloseable(pool)) { in testAdaptToCallableThrowsException() argument
DExecutorsTest.java35 try (ExecutorServiceAutoCloseable cleaner = new ExecutorServiceAutoCloseable(e)) { in testNewWorkStealingPoolDefault() argument
45 try (ExecutorServiceAutoCloseable cleaner = new ExecutorServiceAutoCloseable(e)) { in testNewWorkStealingPoolWithParallelism() argument
DForkJoinPoolTest.java38 try (ExecutorServiceAutoCloseable cleaner = new ExecutorServiceAutoCloseable(pool)) { in testSubmit() argument
51 try (ExecutorServiceAutoCloseable cleaner = new ExecutorServiceAutoCloseable(pool)) { in testGetRunningThreadCount() argument
/libcore/luni/src/test/java/libcore/libcore/util/
DNativeAllocationRegistryTest.java167 Runnable cleaner = registry.registerNativeAllocation(referent, nativePtr); in testEarlyFree() local
171 cleaner.run(); in testEarlyFree()
176 cleaner.run(); in testEarlyFree()
/libcore/ojluni/src/main/java/sun/nio/ch/
DUtil.java296 Cleaner cleaner = ((DirectBuffer)buf).cleaner(); in free() local
297 if (cleaner != null) { in free()
298 cleaner.clean(); in free()
/libcore/luni/src/main/java/java/nio/
DNioUtils.java61 if (dbb.cleaner != null) { in freeDirectBuffer()
62 dbb.cleaner.clean(); in freeDirectBuffer()

123