Swing SwingWorker - max 10 Threats werden gestartet !?

[ralfb1105]

Hallo Community,

ich versuche für mein GUI mehrere "DB Tests" parallel zu starten und nutze dazu den SwingWorker. Das ganze klappt auch anscheinend für bis zu 10 Threats, dann aber anscheinend nicht mehr !!?? Ich habe das mal vereinfacht in folgendes kleines Programm/GUI runtergebrachten um Euch zu zeigen wo mein problem liegt.
Hier erst einmal der komplette Code:

package oracle;

import java.awt.event.ActionEvent;
import java.awt.event.ActionListener;
import java.text.DecimalFormat;
import java.util.List;
import java.util.Timer;
import java.util.TimerTask;
import java.util.Vector;
import java.util.concurrent.TimeUnit;
import javax.swing.JButton;
import javax.swing.JLabel;
import javax.swing.JScrollPane;
import javax.swing.JSlider;
import javax.swing.JTextArea;
import javax.swing.JToggleButton;
import javax.swing.WindowConstants;
import javax.swing.border.BevelBorder;
import javax.swing.border.SoftBevelBorder;
import javax.swing.SwingUtilities;
import javax.swing.SwingWorker;


/**
* This code was edited or generated using CloudGarden's Jigloo
* SWT/Swing GUI Builder, which is free for non-commercial
* use. If Jigloo is being used commercially (ie, by a corporation,
* company or business for any purpose whatever) then you
* should purchase a license for each developer using Jigloo.
* Please visit www.cloudgarden.com for details.
* Use of Jigloo implies acceptance of these licensing terms.
* A COMMERCIAL LICENSE HAS NOT BEEN PURCHASED FOR
* THIS MACHINE, SO JIGLOO OR THIS CODE CANNOT BE USED
* LEGALLY FOR ANY CORPORATE OR COMMERCIAL PURPOSE.
*/
@SuppressWarnings("serial")
public class TestMultipleUser extends javax.swing.JFrame {
    private JTextArea jTAOutput;
    private JButton jBExit;
    private JToggleButton jTBStartStop;
    private JSlider jSNoUser;
    private JLabel jLabel1;
    private JLabel jLTestRemaining;
    private JScrollPane jScrollPane1;
    private ProcessWorkerCounter pc;
    private Vector<ProcessWorkerDbTest> vcDbTest;

    /**
    * Auto-generated main method to display this JFrame
    */
    public static void main(String[] args) {
        SwingUtilities.invokeLater(new Runnable() {
            public void run() {
                TestMultipleUser inst = new TestMultipleUser();
                inst.setLocationRelativeTo(null);
                inst.setVisible(true);
            }
        });
    }
   
    public class ProcessWorkerCounter extends SwingWorker<Void, String>
    {
        private JLabel jLCounter;
        private long seconds;
        private Timer timerCounter;
        private Vector<ProcessWorkerDbTest> vcDbTest;
       
       
        //ProcessWorkerDbTest pt = new ProcessWorkerDbTest(jTAOutput);
       
        //Konstruktor
        public ProcessWorkerCounter(JLabel counter, long seconds, Vector<ProcessWorkerDbTest> vcDbTest)
        {
            this.jLCounter = counter;
            this.seconds = seconds;
            this.vcDbTest = vcDbTest;
        }
       
       
        //getter - Return Timer Object
        public Timer getTimerCounter() {
            return timerCounter;
        }
       
        class TaskCounter extends TimerTask
        {
           
           
          @Override public void run()
          {
              seconds--;
              long hh = seconds / 3600;
              long mm = (seconds % 3600) / 60;
              long ss = seconds - (hh * 3600) - (mm * 60);
              DecimalFormat format = new DecimalFormat("00");
              publish(format.format(hh) + ":" + format.format(mm) + ":" + format.format(ss));
              if (seconds == 0) {
                  for (int i=0; i < vcDbTest.size(); i++) {
                      ((ProcessWorkerDbTest)vcDbTest.elementAt(i)).cancel(true);
                    }
                  //pt.cancel(true);
                  pc.getTimerCounter().cancel();
                publish("Test finished!");
              } 
          }
        }
   
        @Override
        protected Void doInBackground() throws Exception
        {
            //hier l�uft alles in einem eigenen Thread (nebenl�ufig) ab. Es ist also egal wie lange die Abarbeitung hier dauert.
           
            this.timerCounter = new Timer();
            timerCounter.scheduleAtFixedRate(new TaskCounter(), 0, 1000);
           
            System.out.println("Start Tests: " + vcDbTest.size());
            for (int i=0; i < vcDbTest.size(); i++) {
                ((ProcessWorkerDbTest)vcDbTest.elementAt(i)).execute();
            }   
            return null;
        }
       
        @Override
        protected void process(List<String> chunks)
        {
            //hier l�uft alles auf dem EDT (Event Dispatch Thread). Darum k�nnen (und sollten) wir hier die GUI Komponenten manipulieren.
            for(int i = 0; i < chunks.size(); i++)
            {
                jLCounter.setText(chunks.get(i));
                //jTAOutput.append(System.getProperty("line.separator"));
            }
        }
    }
   
    public class ProcessWorkerDbTest extends SwingWorker<Void, String>
    {
        private JTextArea jTAOutput;
       
        public ProcessWorkerDbTest(JTextArea textArea)
        {
            this.jTAOutput = textArea;
        }


        @Override
        protected Void doInBackground() throws Exception
        {
            //hier l�uft alles in einem eigenen Thread (nebenl�ufig) ab. Es ist also egal wie lange die Abarbeitung hier dauert.
           
            while (!isCancelled()) {
                for (int i=1000; i>=0; i--) {
                    publish("DB Test Run: " + i);
                    TimeUnit.SECONDS.sleep(1);
                }
            }
           
            return null;
        }
       
       
       
        @Override
        protected void process(List<String> chunks)
        {
            //hier l�uft alles auf dem EDT (Event Dispatch Thread). Darum k�nnen (und sollten) wir hier die GUI Komponenten manipulieren.
            for(int i = 0; i < chunks.size(); i++)
            {
                jTAOutput.append(chunks.get(i));
                jTAOutput.append(System.getProperty("line.separator"));
            }
        }
    }
   
   
   
   
    public TestMultipleUser() {
        super();
        initGUI();
    }
   
    private void initGUI() {
        try {
            setDefaultCloseOperation(WindowConstants.DISPOSE_ON_CLOSE);
            getContentPane().setLayout(null);
            this.setTitle("Test Multiple User");
            {
                jScrollPane1 = new JScrollPane();
                getContentPane().add(jScrollPane1);
                jScrollPane1.setBounds(24, 142, 816, 216);
                {
                    jTAOutput = new JTextArea();
                    jScrollPane1.setViewportView(jTAOutput);
                    jTAOutput.setBounds(24, 142, 816, 216);
                    jTAOutput.setEditable(false);
                }
            }
            {
                jBExit = new JButton();
                getContentPane().add(jBExit);
                jBExit.setText("Exit");
                jBExit.setBounds(852, 335, 80, 23);
                jBExit.addActionListener(new ActionListener() {
                    public void actionPerformed(ActionEvent evt) {
                        jBExitActionPerformed(evt);
                    }
                });
            }
            {
                jLTestRemaining = new JLabel();
                getContentPane().add(jLTestRemaining);
                jLTestRemaining.setBounds(136, 110, 130, 20);
                jLTestRemaining.setBorder(new SoftBevelBorder(BevelBorder.LOWERED, null, null, null, null));
            }
            {
                jLabel1 = new JLabel();
                getContentPane().add(jLabel1);
                jLabel1.setText("Remining Time");
                jLabel1.setBounds(36, 114, 111, 16);
            }
            {
                jSNoUser = new JSlider();
                getContentPane().add(jSNoUser);
                jSNoUser.setBounds(352, 81, 237, 45);
                jSNoUser.setMinimum(1);
                jSNoUser.setMaximum(19);
                jSNoUser.setMajorTickSpacing(3);
                jSNoUser.setMinorTickSpacing(1);
                jSNoUser.createStandardLabels(1);
                jSNoUser.setPaintLabels(true);
                jSNoUser.setPaintTicks(true);
                jSNoUser.setValue(4);
                jSNoUser.setFont(new java.awt.Font("Segoe UI",0,11));
            }
            {
                jTBStartStop = new JToggleButton();
                getContentPane().add(jTBStartStop);
                jTBStartStop.setText("Start-Stop");
                jTBStartStop.setBounds(656, 92, 118, 34);
                jTBStartStop.addActionListener(new ActionListener() {
                    public void actionPerformed(ActionEvent evt) {
                        jTBStartStopActionPerformed(evt);
                    }
                });
            }
            pack();
            this.setSize(959, 415);
        } catch (Exception e) {
            //add your error handling code here
            e.printStackTrace();
        }
    }
   
    private void jBExitActionPerformed(ActionEvent evt) {
        System.exit(0);
    }
   
    private void jTBStartStopActionPerformed(ActionEvent evt) {
        toggleButtonAction();
    }
   
    private void toggleButtonAction() {
        if (jTBStartStop.isSelected()) {
            long seconds = 30;
           
            this.vcDbTest = new Vector<ProcessWorkerDbTest>();
           
            for (int i = 1; i <= jSNoUser.getValue(); i++) {
                vcDbTest.add(new ProcessWorkerDbTest(jTAOutput));
            }
           
            this.pc = new ProcessWorkerCounter(jLTestRemaining, seconds, vcDbTest);
            pc.execute();
        } else {
            System.out.println("Stop Tests: " + vcDbTest.size());
            for (int i=0; i < vcDbTest.size(); i++) {
                  ((ProcessWorkerDbTest)vcDbTest.elementAt(i)).cancel(true);
                }
            pc.getTimerCounter().cancel();
            System.out.println("Test stopped!!");
        }
    }
}

Es wird hier beim drücken des Toggle-Button der ProcessWorkerCounter gestartet, der dann die Test Zeit "aufzieht" und dann x-mal, abhängig vom eingestellten Wert der über jSlider eingestellt ist, die Klasse ProcessWorkerDbTest zu starten. Hier wird nur eine Text Zeile im jTextArea ausgegeben um zu zeigen das der Test läuft.

Problem:

Bis zu 10 geht alles wie gewünscht, stelle ich den Slider auf > 10 werden dennoch nur 10 Zeilen ausgegeben, sprich die Klasse wurde anscheinend nur 10x gestartet!? Die Objekte der Klasse ProcessWorkerDbTest habe ich einem Vector abgelegt, da ich gelesen habe das dieser ThreadSave ist - bin mir nicht sicher ob das so richtig ist.

Habt Ihr eine Idee was ich hier falsch mache?

Danke wie immer für Eure Unterstützung!!

LG

Ralf

 

[ralfb1105]

Hallo,

Da ich bis jetzt keine Erklärung oder Lösung für das oben beschriebene Verhalten gefunden habe würde es mich sehr interessieren ob das Verhalten in Eurer Umgebung auch existiert wenn Ihr das oben gezeigte Programm bei Euch startet. Wenn also jemand die Zeit findet das mal kurz zu testen, wäre ich sehr dankbar ... natürlich auch für alle anderen theoretischen Tips

Danke schon mal!

Gruß

Ralf

 

[ralfb1105]

Hallo,

kurz zur Info, scheint also, wie vermutet ein Fehler im Programm auf meiner Seite zu sein. Ich habe es gerade auch unter Windows und MacOS getestet - gleiches Verhalten, also kein Problem der Umgebung. Tritt sowohl beim Aufruf unter Eclipse als auch beim Aufruf der erzeugten jar Datei auf.

Bin also auf Eure Hilfe angewiesen, denn mir fehlen hier die Ideen und die Erfahrung wie man so etwas debuggen könnte ... Mr. Google gibt auch nicht viel her.

Danke.

Gruß

Ralf

 

[mihe7]

Die Erklärung ist relativ einfach: der von SwingWorker verwendete ExecutorService ist mir einer begrenzten Anzahl an Worker-Threads konfiguriert. Die Implementierung im OpenJDK hat z. B. 10.

Will man mehr, kann man einen eigenen ExecutorService verwenden:

import java.util.concurrent.*;

...
            ExecutorService es = new ThreadPoolExecutor(20, 20, 1L,
                    TimeUnit.MINUTES, new LinkedBlockingQueue<Runnable>());
            for (int i=0; i < vcDbTest.size(); i++) {
                es.execute((Runnable)vcDbTest.elementAt(i));
//                ((ProcessWorkerDbTest)vcDbTest.elementAt(i)).execute();
            }
...

 

[ralfb1105]

Hallo,

vielen Dank für Deinen Vorschlag, das kling sehr plausibel, doch leider bekomme ich in Eclipse einen Fehler wenn ich versuche in meinem Code das Objekt vom Type ExecutorService zu erstellen. Folgende Zeile habe ich in der Klasse "ProcessWorkerCounter" eingefügt:

ExecutorService es = new ThreadPoolExecutor(20, 20, 1L,TimeUnit.MINUTES, new LinkedBlockingQueue<Runnable>());

Den import für den ExecutorService habe ich durchgeführt, Eclipse beschwert sich über ThreadPoolExecutor und LinkedBlockingQueue, die er nicht "auflösen" kann --> "can not be resolved to a type".

Könntest Du mir bitte noch eine Hilfestellung geben wie ich diesen Fehler bewerten muss bzw. beheben kann?

Danke nochmals für Deine Hilfe!

Gruß

Ralf

 

[ralfb1105]

Sorry ... ich nehme alles zurück und behaupte das Gegenteil
Der Fehler saß mal wieder vor dem Bildschirm, habe den import java.util.concurrent.* nicht gemacht und zu Anfang nur den "import java.util.concurrent.ExecutorService". Da es dann noch mehrere Fehler gab hat mich Eclipse nicht auf die fehlenden imports hingewiesen.

So wie Du es geschrieben hast funktioniert es einwandfrei - VIELEN DANK für diese Info, das hilft mir sehr!!
Sorry nochmals für die Verwirrung ... das nächste Mal erst Debugger und dann schreiben

Gruß

Ralf