test/tools/javac/lib/JavacTestingAbstractThreadedTest.java

Mon, 21 Jan 2013 20:13:56 +0000

author
mcimadamore
date
Mon, 21 Jan 2013 20:13:56 +0000
changeset 1510
7873d37f5b37
parent 1482
954541f13717
child 1520
5c956be64b9e
permissions
-rw-r--r--

8005244: Implement overload resolution as per latest spec EDR
Summary: Add support for stuck expressions and provisional applicability
Reviewed-by: jjg

vromero@1482 1 /*
vromero@1482 2 * Copyright (c) 2010, 2013, Oracle and/or its affiliates. All rights reserved.
vromero@1482 3 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
vromero@1482 4 *
vromero@1482 5 * This code is free software; you can redistribute it and/or modify it
vromero@1482 6 * under the terms of the GNU General Public License version 2 only, as
vromero@1482 7 * published by the Free Software Foundation.
vromero@1482 8 *
vromero@1482 9 * This code is distributed in the hope that it will be useful, but WITHOUT
vromero@1482 10 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
vromero@1482 11 * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License
vromero@1482 12 * version 2 for more details (a copy is included in the LICENSE file that
vromero@1482 13 * accompanied this code).
vromero@1482 14 *
vromero@1482 15 * You should have received a copy of the GNU General Public License version
vromero@1482 16 * 2 along with this work; if not, write to the Free Software Foundation,
vromero@1482 17 * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
vromero@1482 18 *
vromero@1482 19 * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA
vromero@1482 20 * or visit www.oracle.com if you need additional information or have any
vromero@1482 21 * questions.
vromero@1482 22 */
vromero@1482 23
vromero@1482 24 import java.io.PrintWriter;
vromero@1482 25 import java.io.StringWriter;
vromero@1482 26 import java.util.concurrent.ExecutorService;
vromero@1482 27 import java.util.concurrent.Executors;
vromero@1482 28 import java.util.concurrent.ThreadFactory;
vromero@1482 29 import java.util.concurrent.atomic.AtomicInteger;
vromero@1482 30 import javax.tools.JavaCompiler;
vromero@1482 31 import javax.tools.StandardJavaFileManager;
vromero@1482 32 import javax.tools.ToolProvider;
vromero@1482 33
vromero@1482 34 /**
vromero@1482 35 * An abstract superclass for threaded tests.
vromero@1482 36 *
vromero@1482 37 * This class will try to read a property named test.concurrency.
vromero@1482 38 * The property can be provided by passing this option to jtreg:
vromero@1482 39 * -javaoption:-Dtest.concurrency=#
vromero@1482 40 *
vromero@1482 41 * If the property is not set the class will use a heuristic to determine the
vromero@1482 42 * maximum number of threads that can be fired to execute a given test.
vromero@1482 43 */
vromero@1482 44 public abstract class JavacTestingAbstractThreadedTest {
vromero@1482 45
vromero@1482 46 protected static int getThreadPoolSize() {
vromero@1482 47 Integer testConc = Integer.getInteger("test.concurrency");
vromero@1482 48 if (testConc != null) return testConc;
vromero@1482 49 int cores = Runtime.getRuntime().availableProcessors();
vromero@1482 50 return Math.max(2, Math.min(8, cores / 2));
vromero@1482 51 }
vromero@1482 52
vromero@1482 53 protected static void checkAfterExec() throws InterruptedException {
vromero@1482 54 checkAfterExec(true);
vromero@1482 55 };
vromero@1482 56
vromero@1482 57 protected static boolean throwAssertionOnError = true;
vromero@1482 58
vromero@1482 59 protected static boolean printAll = false;
vromero@1482 60
vromero@1482 61 protected static StringWriter errSWriter = new StringWriter();
vromero@1482 62 protected static PrintWriter errWriter = new PrintWriter(errSWriter);
vromero@1482 63
vromero@1482 64 protected static StringWriter outSWriter = new StringWriter();
vromero@1482 65 protected static PrintWriter outWriter = new PrintWriter(outSWriter);
vromero@1482 66
vromero@1482 67 protected static void checkAfterExec(boolean printCheckCount)
vromero@1482 68 throws InterruptedException {
vromero@1482 69 pool.shutdown();
vromero@1482 70 while (!pool.isTerminated()) {
vromero@1482 71 Thread.sleep(10);
vromero@1482 72 }
vromero@1482 73 if (errCount.get() > 0) {
vromero@1482 74 if (throwAssertionOnError) {
vromero@1482 75 closePrinters();
vromero@1482 76 System.err.println(errSWriter.toString());
vromero@1482 77 throw new AssertionError(
vromero@1482 78 String.format("%d errors found", errCount.get()));
vromero@1482 79 } else {
vromero@1482 80 System.err.println(
vromero@1482 81 String.format("%d errors found", errCount.get()));
vromero@1482 82 }
vromero@1482 83 } else if (printCheckCount) {
vromero@1482 84 outWriter.println("Total check executed: " + checkCount.get());
vromero@1482 85 }
vromero@1482 86 closePrinters();
vromero@1482 87 if (printAll) {
vromero@1482 88 System.out.println(errSWriter.toString());
vromero@1482 89 System.out.println(outSWriter.toString());
vromero@1482 90 }
vromero@1482 91 }
vromero@1482 92
vromero@1482 93 protected static void closePrinters() {
vromero@1482 94 errWriter.close();
vromero@1482 95 outWriter.close();
vromero@1482 96 }
vromero@1482 97
vromero@1482 98 protected static void processException(Throwable t) {
vromero@1482 99 errCount.incrementAndGet();
vromero@1482 100 t.printStackTrace(errWriter);
vromero@1482 101 pool.shutdown();
vromero@1482 102 }
vromero@1482 103
vromero@1482 104 //number of checks executed
vromero@1482 105 protected static AtomicInteger checkCount = new AtomicInteger();
vromero@1482 106
vromero@1482 107 //number of errors found while running combo tests
vromero@1482 108 protected static AtomicInteger errCount = new AtomicInteger();
vromero@1482 109
vromero@1482 110 //create default shared JavaCompiler - reused across multiple compilations
vromero@1482 111 protected static JavaCompiler comp = ToolProvider.getSystemJavaCompiler();
vromero@1482 112
vromero@1482 113 protected static ExecutorService pool = Executors.newFixedThreadPool(
vromero@1482 114 getThreadPoolSize(), new ThreadFactory() {
vromero@1482 115 @Override
vromero@1482 116 public Thread newThread(Runnable r) {
vromero@1482 117 Thread t = new Thread(r);
vromero@1482 118 t.setUncaughtExceptionHandler(new Thread.UncaughtExceptionHandler() {
vromero@1482 119 @Override
vromero@1482 120 public void uncaughtException(Thread t, Throwable e) {
vromero@1482 121 pool.shutdown();
vromero@1482 122 errCount.incrementAndGet();
vromero@1482 123 e.printStackTrace(System.err);
vromero@1482 124 }
vromero@1482 125 });
vromero@1482 126 return t;
vromero@1482 127 }
vromero@1482 128 });
vromero@1482 129
vromero@1482 130 /*
vromero@1482 131 * File manager is not thread-safe so it cannot be re-used across multiple
vromero@1482 132 * threads. However we cache per-thread FileManager to avoid excessive
vromero@1482 133 * object creation
vromero@1482 134 */
vromero@1482 135 protected static final ThreadLocal<StandardJavaFileManager> fm =
vromero@1482 136 new ThreadLocal<StandardJavaFileManager>() {
vromero@1482 137 @Override protected StandardJavaFileManager initialValue() {
vromero@1482 138 return comp.getStandardFileManager(null, null, null);
vromero@1482 139 }
vromero@1482 140 };
vromero@1482 141
vromero@1482 142 }

mercurial