1 /* 2 * Copyright (c) 2014, 2018, Oracle and/or its affiliates. All rights reserved. 3 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER. 4 * 5 * This code is free software; you can redistribute it and/or modify it 6 * under the terms of the GNU General Public License version 2 only, as 7 * published by the Free Software Foundation. 8 * 9 * This code is distributed in the hope that it will be useful, but WITHOUT 10 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or 11 * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License 12 * version 2 for more details (a copy is included in the LICENSE file that 13 * accompanied this code). 14 * 15 * You should have received a copy of the GNU General Public License version 16 * 2 along with this work; if not, write to the Free Software Foundation, 17 * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA. 18 * 19 * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA 20 * or visit www.oracle.com if you need additional information or have any 21 * questions. 22 */ 23 package gc.g1.unloading.check; 24 25 26 import gc.g1.unloading.ExecutionTask; 27 28 import java.lang.ref.Reference; 29 import java.lang.ref.ReferenceQueue; 30 import java.util.*; 31 32 import nsk.share.test.ExecutionController; 33 34 /** 35 * This thread listens to queue of phantomized classloaders and marks corresponding assertions as passed. 36 */ 37 public class PhantomizationServiceThread extends ExecutionTask { 38 39 private static final int TIMEOUT = 100; 40 41 private Map<Reference<?>, PhantomizedAssertion> map = new HashMap<>(); 42 43 private ReferenceQueue queue = new ReferenceQueue(); 44 45 public PhantomizationServiceThread(ExecutionController executionController) { 46 super(executionController); 47 } 48 49 public void add(Reference ref, PhantomizedAssertion assertion) { 50 map.put(ref, assertion); 51 } 52 53 public ReferenceQueue getQueue() { 54 return queue; 55 } 56 57 @Override 58 protected void task() throws Exception { 59 Reference ref = queue.remove(TIMEOUT); 60 PhantomizedAssertion assertion = map.remove(ref); 61 if (assertion != null) { 62 assertion.setPhantomized(); 63 } 64 } 65 66 }