Test Twenty Threads Running

This is part of JavaUnitTestChallengeSolved. -- DonWells

---

I use two arrays to hold my threads, 10 each.

public class TwentyThreadsTogether extends Test {
public BoundedBuffer buffer;
public PutThread putThreads [];
public TakeThread takeThreads [];
public void setUp(){
buffer = new BoundedBuffer();
putThreads = new PutThread [10];
takeThreads = new TakeThread [10];
for (int each = 0; each < 10; each++) {
putThreads[each] = new PutThread(buffer);
takeThreads[each] = new TakeThread(buffer);}}
public void tearDown(){
for (int each = 0; each < 10; each++) {
putThreads[each].stop();
takeThreads[each].stop();}}
public void runTest (){
TakeThread.resetOutput();
for (int each = 0; each < 10; each++) {
takeThreads[each].start();};
for (int each = 0; each < 10; each++) {
putThreads[each].start();};
waitForTakeToFinish();
should(TakeThread.outputLength() == 50, "output was too short");
should(TakeThread.doesOuputHaveTenOf("a"), "should get ten a");
should(TakeThread.doesOuputHaveTenOf("b"), "should get ten b");
should(TakeThread.doesOuputHaveTenOf("c"), "should get ten c");
should(TakeThread.doesOuputHaveTenOf("d"), "should get ten d");
should(TakeThread.doesOuputHaveTenOf("e"), "should get ten e");}
public void waitForTakeToFinish(){
try {
for (int each = 0; each < 10; each++) {
takeThreads[each].join(4000);}}
catch (InterruptedException exception) {};}
}


I also modified the TakeThread so that it can hold 50 strings of output and added the doesOuputHaveTenOf method, which is almost identical to the two version. I refactored out the part which counts how many of a string there are into a separate method.

public static boolean doesOuputHaveTwoOf (String aValue){
return howManyOf(aValue) == 2;}
public static boolean doesOuputHaveTenOf (String aValue){
return howManyOf(aValue) == 10;}
public static int howManyOf (String aValue){
int howMany = 0;
for (int each = 0; each < outputLength; each++){
if (output[each] == aValue) howMany++;}
return howMany;}
public static String outputString (){
String outputAsString = "";
for (int each = 0; each < outputLength; each++){
outputAsString += output[each];};
return outputAsString;}
public static int outputLength(){
return outputString().length();}


Now I can try it. This test runs just fine too.