diff options
Diffstat (limited to 'src/test/java/org/apache/commons/lang3/builder/ReflectionToStringBuilderMutateInspectConcurrencyTest.java')
-rw-r--r-- | src/test/java/org/apache/commons/lang3/builder/ReflectionToStringBuilderMutateInspectConcurrencyTest.java | 214 |
1 files changed, 107 insertions, 107 deletions
diff --git a/src/test/java/org/apache/commons/lang3/builder/ReflectionToStringBuilderMutateInspectConcurrencyTest.java b/src/test/java/org/apache/commons/lang3/builder/ReflectionToStringBuilderMutateInspectConcurrencyTest.java index 5227b8997..7fbf50679 100644 --- a/src/test/java/org/apache/commons/lang3/builder/ReflectionToStringBuilderMutateInspectConcurrencyTest.java +++ b/src/test/java/org/apache/commons/lang3/builder/ReflectionToStringBuilderMutateInspectConcurrencyTest.java @@ -1,107 +1,107 @@ -/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.commons.lang3.builder;
-
-import java.util.LinkedList;
-import java.util.Random;
-
-import org.junit.Ignore;
-import org.junit.Test;
-
-/**
- * Tests concurrent access for {@link ReflectionToStringBuilder}.
- * <p>
- * The {@link ToStringStyle} class includes a registry to avoid infinite loops for objects with circular references. We
- * want to make sure that we do not get concurrency exceptions accessing this registry.
- * </p>
- *
- * @see <a href="https://issues.apache.org/jira/browse/LANG-762">[LANG-762] Handle or document ReflectionToStringBuilder
- * and ToStringBuilder for collections that are not thread safe</a>
- * @since 3.1
- */
-public class ReflectionToStringBuilderMutateInspectConcurrencyTest {
-
- class TestFixture {
- final private LinkedList<Integer> listField = new LinkedList<Integer>();
- final private Random random = new Random();
- private final int N = 100;
-
- public TestFixture() {
- synchronized (this) {
- for (int i = 0; i < N; i++) {
- listField.add(Integer.valueOf(i));
- }
- }
- }
-
- public synchronized void add() {
- listField.add(Integer.valueOf(random.nextInt(N)));
- }
-
- public synchronized void delete() {
- listField.remove(Integer.valueOf(random.nextInt(N)));
- }
- }
-
- class MutatingClient implements Runnable {
- final private TestFixture testFixture;
- final private Random random = new Random();
-
- public MutatingClient(final TestFixture testFixture) {
- this.testFixture = testFixture;
- }
-
- @Override
- public void run() {
- if (random.nextBoolean()) {
- testFixture.add();
- } else {
- testFixture.delete();
- }
- }
- }
-
- class InspectingClient implements Runnable {
- final private TestFixture testFixture;
-
- public InspectingClient(final TestFixture testFixture) {
- this.testFixture = testFixture;
- }
-
- @Override
- public void run() {
- ReflectionToStringBuilder.toString(testFixture);
- }
- }
-
- @Test
- @Ignore
- public void testConcurrency() throws Exception {
- final TestFixture testFixture = new TestFixture();
- final int numMutators = 10;
- final int numIterations = 10;
- for (int i = 0; i < numIterations; i++) {
- for (int j = 0; j < numMutators; j++) {
- final Thread t = new Thread(new MutatingClient(testFixture));
- t.start();
- final Thread s = new Thread(new InspectingClient(testFixture));
- s.start();
- }
- }
- }
-}
+/* + * Licensed to the Apache Software Foundation (ASF) under one or more + * contributor license agreements. See the NOTICE file distributed with + * this work for additional information regarding copyright ownership. + * The ASF licenses this file to You under the Apache License, Version 2.0 + * (the "License"); you may not use this file except in compliance with + * the License. You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +package org.apache.commons.lang3.builder; + +import java.util.LinkedList; +import java.util.Random; + +import org.junit.Ignore; +import org.junit.Test; + +/** + * Tests concurrent access for {@link ReflectionToStringBuilder}. + * <p> + * The {@link ToStringStyle} class includes a registry to avoid infinite loops for objects with circular references. We + * want to make sure that we do not get concurrency exceptions accessing this registry. + * </p> + * + * @see <a href="https://issues.apache.org/jira/browse/LANG-762">[LANG-762] Handle or document ReflectionToStringBuilder + * and ToStringBuilder for collections that are not thread safe</a> + * @since 3.1 + */ +public class ReflectionToStringBuilderMutateInspectConcurrencyTest { + + class TestFixture { + final private LinkedList<Integer> listField = new LinkedList<Integer>(); + final private Random random = new Random(); + private final int N = 100; + + public TestFixture() { + synchronized (this) { + for (int i = 0; i < N; i++) { + listField.add(Integer.valueOf(i)); + } + } + } + + public synchronized void add() { + listField.add(Integer.valueOf(random.nextInt(N))); + } + + public synchronized void delete() { + listField.remove(Integer.valueOf(random.nextInt(N))); + } + } + + class MutatingClient implements Runnable { + final private TestFixture testFixture; + final private Random random = new Random(); + + public MutatingClient(final TestFixture testFixture) { + this.testFixture = testFixture; + } + + @Override + public void run() { + if (random.nextBoolean()) { + testFixture.add(); + } else { + testFixture.delete(); + } + } + } + + class InspectingClient implements Runnable { + final private TestFixture testFixture; + + public InspectingClient(final TestFixture testFixture) { + this.testFixture = testFixture; + } + + @Override + public void run() { + ReflectionToStringBuilder.toString(testFixture); + } + } + + @Test + @Ignore + public void testConcurrency() throws Exception { + final TestFixture testFixture = new TestFixture(); + final int numMutators = 10; + final int numIterations = 10; + for (int i = 0; i < numIterations; i++) { + for (int j = 0; j < numMutators; j++) { + final Thread t = new Thread(new MutatingClient(testFixture)); + t.start(); + final Thread s = new Thread(new InspectingClient(testFixture)); + s.start(); + } + } + } +} |