/* * Copyright (c) 2020, 2022, Oracle and/or its affiliates. All rights reserved. * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER. * * This code is free software; you can redistribute it and/or modify it * under the terms of the GNU General Public License version 2 only, as * published by the Free Software Foundation. * * This code is distributed in the hope that it will be useful, but WITHOUT * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or * FITNESS FOR A PARTICULAR PURPOSE. See the GNU General Public License * version 2 for more details (a copy is included in the LICENSE file that * accompanied this code). * * You should have received a copy of the GNU General Public License version * 2 along with this work; if not, write to the Free Software Foundation, * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA. * * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA * or visit www.oracle.com if you need additional information or have any * questions. /** * @test * @summary Unit tests for java.lang.ThreadGroup * @run testng BasicTests import java.lang.ref.WeakReference;import java.util.Arrays;import java.util.Objects;import java.util.Set;import java.util.concurrent.locks.LockSupport;import java.util.stream.Collectors;import org.testng.annotations.Test;import static org.testng.Assert .*;public class BasicTests {public void testGetName1() {new ThreadGroup(null );null );public void testGetName2() {new ThreadGroup("fred" );"fred" );public void testGetParent() {new ThreadGroup("group1" );new ThreadGroup(group1, "group2" );new ThreadGroup(group2, "group3" );Thread .currentThread().getThreadGroup());public void testParentOf() {new ThreadGroup("group1" );new ThreadGroup(group1, "group2" );new ThreadGroup(group2, "group3" );null ));null ));null ));public void testActiveCount1() {new ThreadGroup("group" );thread = TestThread.start(group, "foo" );try {finally {thread .terminate();public void testActiveCount2() {new ThreadGroup("group1" );new ThreadGroup(group1, "group2" );"foo" );try {"bar" );try {finally {finally {public void enumerateThreads1() {new ThreadGroup("group" );Thread [] threads = new Thread [100];null );true ) == 0);null );false ) == 0);null );thread = TestThread.start(group, "foo" );try {null );thread );null );null );true ) == 1);thread );null );null );false ) == 1);thread );null );finally {thread .terminate();public void enumerateThreads2() {new ThreadGroup("group1" );new ThreadGroup(group1, "group2" );Thread [] threads = new Thread [100];null );true ) == 0);null );false ) == 0);null );null );true ) == 0);null );false ) == 0);null );"foo" );try {null );null );null );true ) == 1);null );null );false ) == 1);null );null );null );true ) == 0);null );false ) == 0);null );"bar" );try {null );null );null );true ) == 2);null );null );false ) == 1);null );null );null );null );true ) == 1);null );null );false ) == 1);null );finally {null );null );true ) == 1);null );false ) == 1);null );null );true ) == 0);null );false ) == 0);null );finally {public void enumerateThreads3() {new ThreadGroup("group1" );new ThreadGroup(group1, "group2" );new ThreadGroup(group2, "group3" );Thread [] threads = new Thread [100];true ) == 0);false ) == 0);true ) == 0);false ) == 0);true ) == 0);false ) == 0);"foo" );try {null );true ) == 1);false ) == 0);null );null );true ) == 1);null );false ) == 1);true ) == 0);false ) == 0);"bar" );try {null );null );true ) == 2);false ) == 0);null );null );true ) == 2);null );false ) == 1);null );null );true ) == 1);null );false ) == 1);finally {null );null );null );true ) == 1);null );null );false ) == 0);null );null );null );null );true ) == 1);null );null );false ) == 1);null );null );null );true ) == 0);null );false ) == 0);null );finally {true ) == 0);false ) == 0);true ) == 0);false ) == 0);true ) == 0);false ) == 0);/** * Test enumerate(Thread[]) with an array of insufficient size public void enumerateThreads4() {new ThreadGroup("group" );// array too small Thread [] threads = new Thread [1];"thread1" );"thread2" );try {null );null );true ) == 1);null );false ) == 1);finally {public void testActiveGroupCount() throws Exception {new ThreadGroup("group1" );new ThreadGroup(group1, "group2" );new ThreadGroup(group2, "group3" );// unreference group3 and wait for it to be GC'ed var ref = new WeakReference<>(group3);null ;while (ref.get() != null ) {Thread .sleep(50);public void testEnumerateGroups1() throws Exception {new ThreadGroup[100];new ThreadGroup("group1" );null );true ) == 0);null );false ) == 0);null );new ThreadGroup(group1, "group2" );null );null );null );true ) == 1);null );null );false ) == 1);null );new ThreadGroup(group2, "group3" );null );null );null );true ) == 2);null );null );false ) == 1);null );null );null );null );true ) == 1);null );null );false ) == 1);null );null );null );null );true ) == 0);null );null );false ) == 0);null );// unreference group3 and wait for it to be GC'ed var ref = new WeakReference<>(group3);null );null ;while (ref.get() != null ) {Thread .sleep(50);null );null );null );true ) == 1);null );null );false ) == 1);null );/** * Test enumerate(ThreadGroup[]) with an array of insufficient size public void testEnumerateGroups2() throws Exception {new ThreadGroup("group" );new ThreadGroup(group, "child1" );new ThreadGroup(group,"child2" );// array too small new ThreadGroup[1];null );null );true ) == 1);null );false ) == 1);public void testMaxPriority1() {new ThreadGroup("group" );final int maxPriority = group.getMaxPriority();Thread .currentThread().getThreadGroup().getMaxPriority());Thread .MIN_PRIORITY-1);Thread .MAX_PRIORITY+1);if (maxPriority > Thread .MIN_PRIORITY) {public void testMaxPriority2() {new ThreadGroup("group1" );int maxPriority = group1.getMaxPriority();if (maxPriority > Thread .MIN_PRIORITY) {new ThreadGroup(group1, "group2" );new ThreadGroup(group2, "group3" );Thread .MIN_PRIORITY);Thread .MIN_PRIORITY);Thread .MIN_PRIORITY);Thread .MIN_PRIORITY);Thread .MIN_PRIORITY);Thread .MIN_PRIORITY);Thread .MIN_PRIORITY);Thread .MIN_PRIORITY);Thread .MIN_PRIORITY);public void testMaxPriority3() {new ThreadGroup("group" );if (group.getMaxPriority() > Thread .MIN_PRIORITY) {int maxPriority = Thread .MIN_PRIORITY + 1;Thread thread = new Thread (group, () -> { });int priority = thread .getPriority();int expectedPriority = Math.min(Thread .currentThread().getPriority(), maxPriority);thread .setPriority(Thread .MAX_PRIORITY);thread .getPriority() == maxPriority);thread .setPriority(maxPriority);thread .getPriority() == maxPriority);thread .setPriority(Thread .MIN_PRIORITY);thread .getPriority() == Thread .MIN_PRIORITY);public void testInterrupt1() {new ThreadGroup("group" );thread = TestThread.start(group, "foo" );try {finally {thread .terminate();thread .wasInterrupted());public void testInterrupt2() {new ThreadGroup("group1" );new ThreadGroup(group1, "group2" );"foo" );"bar" );try {finally {public void testInterrupt3() {new ThreadGroup("group1" );new ThreadGroup(group1, "group2" );"foo" );"bar" );try {finally {public void testDestroy() {new ThreadGroup("group" );// does nothing public void testDaemon() {boolean d = Thread .currentThread().getThreadGroup().isDaemon();new ThreadGroup("group1" );// inherit true );new ThreadGroup(group1, "group2" );// inherit false );new ThreadGroup(group1, "group2" );// inherit public void testList() {new ThreadGroup("foo" );public void testSuspend() {new ThreadGroup("foo" );class , () -> group.suspend());public void testResume() {new ThreadGroup("foo" );class , () -> group.resume());public void testStop() {new ThreadGroup("foo" );class , () -> group.stop());public void testAllowThreadSuspension() {new ThreadGroup("foo" );false ));true ));public void testNull1() {class ,new ThreadGroup(null , "group" ));public void testNull2() {new ThreadGroup("group" );class ,Thread []) null ));public void testNull3() {new ThreadGroup("group" );class ,Thread []) null , false ));public void testNull4() {new ThreadGroup("group" );class ,null ));public void testNull5() {new ThreadGroup("group" );class ,null , false ));private <T> Set<T> toSet(T[] array, int len) {return Arrays.stream(array, 0, len).collect(Collectors.toSet());static class TestThread extends Thread {super (group, name);static TestThread start(ThreadGroup group, String name) {thread = new TestThread(group, name);thread .start();return thread ;private volatile boolean done;private volatile boolean interrupted;public void run() {if (Thread .currentThread() != this )throw new IllegalCallerException();while (!done) {if (Thread .interrupted()) {true ;if (Thread .interrupted()) {true ;boolean wasInterrupted() {return interrupted;void terminate() {true ;this );boolean interrupted = false ;while (isAlive()) {try {Thread .sleep(10);catch (InterruptedException e) {true ;if (interrupted) {Thread .currentThread().interrupt();
Messung V0.5 C=91 H=90 G=90
¤ Dauer der Verarbeitung: 0.15 Sekunden
(vorverarbeitet)
¤ *© Formatika GbR, Deutschland
