Home
last modified time | relevance | path

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

1234

/libcore/ojluni/src/main/java/java/lang/ref/
DCleaner.java140 public CleanerImpl apply(Cleaner cleaner) { in CleanerImpl.setCleanerImplAccess()
141 return cleaner.impl; in CleanerImpl.setCleanerImplAccess()
179 Cleaner cleaner = new Cleaner(); in create() local
180 cleaner.impl.start(cleaner, null); in create()
181 return cleaner; in create()
207 Cleaner cleaner = new Cleaner(); in create() local
208 cleaner.impl.start(cleaner, threadFactory); in create()
209 return cleaner; in create()
219 Cleaner cleaner = new Cleaner(FinalizerReference.queue); in createSystemCleaner() local
220 cleaner.impl.start(cleaner); in createSystemCleaner()
[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.java78 try (PoolCleaner cleaner = cleaner(p)) { in testExecute() argument
92 try (PoolCleaner cleaner = cleaner(p)) { in testSchedule1() argument
113 try (PoolCleaner cleaner = cleaner(p)) { in testSchedule3() argument
133 try (PoolCleaner cleaner = cleaner(p)) { in testSchedule4() argument
155 try (PoolCleaner cleaner = cleaner(p)) { in testSchedule5() argument
184 try (PoolCleaner cleaner = cleaner(p)) { in testFixedRateSequence() argument
213 try (PoolCleaner cleaner = cleaner(p)) { in testFixedDelaySequence() argument
257 try (PoolCleaner cleaner = cleaner(p)) { in testExecuteNull() argument
270 try (PoolCleaner cleaner = cleaner(p)) { in testScheduleNull() argument
284 try (PoolCleaner cleaner = cleaner(p)) { in testSchedule1_RejectedExecutionException() argument
[all …]
DScheduledExecutorSubclassTest.java135 try (PoolCleaner cleaner = cleaner(p)) { in testExecute() argument
150 try (PoolCleaner cleaner = cleaner(p, done)) { in testSchedule1() argument
169 try (PoolCleaner cleaner = cleaner(p)) { in testSchedule3() argument
189 try (PoolCleaner cleaner = cleaner(p)) { in testSchedule4() argument
211 try (PoolCleaner cleaner = cleaner(p)) { in testSchedule5() argument
240 try (PoolCleaner cleaner = cleaner(p)) { in testFixedRateSequence() argument
269 try (PoolCleaner cleaner = cleaner(p)) { in testFixedDelaySequence() argument
313 try (PoolCleaner cleaner = cleaner(p)) { in testExecuteNull() argument
326 try (PoolCleaner cleaner = cleaner(p)) { in testScheduleNull() argument
340 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 …]
/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 …]
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 …]
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 …]
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/lang/ref/
DCleanerTest.java70 static final Cleaner COMMON = CleanerFactory.cleaner();
99 Cleaner cleaner = supplier.get(); in testCleanableActions() local
102 generateCases(cleaner, c -> c.clearRef()); in testCleanableActions()
103 generateCases(cleaner, c -> c.doClean()); in testCleanableActions()
106 generateCases(cleaner, c -> c.doClean(), c -> c.clearRef()); in testCleanableActions()
108 CleanableCase s = setupPhantom(COMMON, cleaner); in testCleanableActions()
109 cleaner = null; in testCleanableActions()
120 Cleaner cleaner = supplier.get(); in testSystemCleanerActions() local
123 generateCases(cleaner, c -> c.clearRef()); in testSystemCleanerActions()
124 generateCases(cleaner, c -> c.doClean()); in testSystemCleanerActions()
[all …]
/libcore/ojluni/src/main/java/jdk/internal/ref/
DCleanerImpl.java83 static CleanerImpl getCleanerImpl(Cleaner cleaner) { in getCleanerImpl() argument
84 return cleanerImplAccess.apply(cleaner); in getCleanerImpl()
113 public void start(Cleaner cleaner, ThreadFactory threadFactory) { in start() argument
114 if (getCleanerImpl(cleaner) != this) { in start()
119 new CleanerCleanable(cleaner); in start()
140 public void start(Cleaner cleaner) { in start() argument
141 if (getCleanerImpl(cleaner) != this) { in start()
197 public PhantomCleanableRef(Object obj, Cleaner cleaner, Runnable action) { in PhantomCleanableRef() argument
198 super(obj, cleaner); in PhantomCleanableRef()
372 CleanerCleanable(Cleaner cleaner) {
[all …]
DPhantomCleanable.java65 public PhantomCleanable(T referent, Cleaner cleaner) { in PhantomCleanable() argument
66 super(Objects.requireNonNull(referent), CleanerImpl.getCleanerImpl(cleaner).queue); in PhantomCleanable()
67 this.list = CleanerImpl.getCleanerImpl(cleaner).phantomCleanableList; in PhantomCleanable()
72 Reference.reachabilityFence(cleaner); in PhantomCleanable()
/libcore/luni/src/main/java/libcore/util/
DNativeAllocationRegistry.java271 Cleaner cleaner = Cleaner.create(referent, thunk); in registerNativeAllocation() local
272 result = new CleanerRunner(cleaner); in registerNativeAllocation()
311 private final Cleaner cleaner; field in NativeAllocationRegistry.CleanerRunner
313 public CleanerRunner(Cleaner cleaner) { in CleanerRunner() argument
314 this.cleaner = cleaner; in CleanerRunner()
318 cleaner.clean(); in run()
/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()
/libcore/luni/src/main/java/android/system/
DSystemCleaner.java49 @NonNull public static Cleaner cleaner() { in cleaner() method in SystemCleaner
50 return CleanerFactory.cleaner(); in cleaner()
/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
/libcore/luni/src/main/java/java/nio/
DNioUtils.java59 if (dbb.cleaner != null) { in freeDirectBuffer()
60 dbb.cleaner.clean(); in freeDirectBuffer()

1234