Ablauf abbrechen und zurück

[Louis2]

Hallo,

mein Prog. verschickt Emails, der Status wird in eine JProgressBar angezeigt.
Nun habe ich auch ein Button eingefügt zum abbrechen, wie kann ich den Vorgang (das Versenden) abbrechen und an die Stelle vor dem Versenden zurückkehren?
[EDIT]Mit dem break geht es nicht so ganz und ich komme ja nicht zurück!

Code

if (main.LogSchalter.equals("NO") | main.LogSchalter.equals("No") 
| main.LogSchalter.equals("no"))
{
    if (action == sendButton) 
    {
        .
        .
        .         
        Runnable r = new Runnable()
        {
            public void run()
            {
                cancelButton.setEnabled(true);
                for ( int i = 1; i <= len; i++ )
                {
                    try
                    {
                        Transport.send(msg);
                    }
                    catch (Exception e)
                    {
                        e.printStackTrace();
                    }
                    final int j=i;
                                    
                    SwingUtilities.invokeLater( new Runnable()
                    {
                        public void run()
                        {
                            bar.setValue(j);
                            valueProg.setText((j) + " of " + len + " Emails");
	        }
                    } );
                    if (action == cancelButton)
                    break; 
// hier soll das Versenden abgebrochen werden und vor 
// if (action == sendButton) zurückkehren.
                }
            }
        };
Thread t = new Thread(r);
t.start();
    }
}

 

[Roar]

ähm indem du einfach auf irgendne boolean variable überprüfst die gesetzt wird wenn ma nabbrechen drückt??
btw 1. es gibt auch ein equalsIgnoreCase() ...
und 2. wenn die methode da im actionListener steht, dann soltle schon der ganze tread mit invokeLater() ausgeführt werden..

 

[Louis2]

Das mit dem "Abbruch" Button habe ich ja schon reingepackt, siehe Code oben, aber mit dem break; stoppt das Programm nur während das Button gedrückt ist, ich will aber, das der aktuelle Vorgang ganz abgebrochen wird...
Bei Threads geht es ja mit stop() und hier? :roll:

 

[Louis2]

Also mit stop() will es auch nicht... ähm... hat keiner eine Ahnung wie ich den Code einfach abbrechen kann, bzw. den runnable Ablauf?
Sollte doch irgendwie gehen, das Button habe ich ja schon...

 

[Louis2]

@Roar: Jetzt verstehe ich erst was Du meinst.
Also ich habe mein Code geändert und zwar in

boolean state = true;
.
.

if (state == true)
{
        if (main.LogSchalter.equals("NO") | main.LogSchalter.equals("No") 
| main.LogSchalter.equals("no"))
        {
            if (action == sendButton) 
            { 
.
.
                try
                {
.
.
                            Runnable r = new Runnable()
                            {
                                public void run()
                                {
                                    cancelButton.setEnabled(true);
                                    try
                                    {
                                        Transport.send(msg);
                                    }
                                    catch (Exception e4)
                                    {
                                        JOptionPane.showMessageDialog(null, 
"Error during transport:" + "\n" + e4.getMessage());
                                    }
                                    j=k;
                                    
                                    SwingUtilities.invokeLater( new Runnable()
                                    {
                                        public void run()
                                        {
                                            bar.setValue(j);
                                            valueProg.setText((j) + " of " + 
leng + " Emails");
                                        }
                                    } );
                                    /*if (action == cancelButton) 
                                        state = false;*/
                                }
                            };
                            Thread t = new Thread(r);
                            t.start();
                                                                                                               
                            main.message.setText("");
                            main.subjectField.setText("");
                            if (action == cancelButton) // Abbruch Button
                               state = false;
.
                }
                catch (Exception e6)
                {
                    JOptionPane.showMessageDialog(null, "Error: Could not create file"); 
                }
            }
        }
     }

Aber es funktioniert immer noch nicht. Wo soll ich denn das

if (action == cancelButton) // Abbruch Button
                               state = false;

richtig positionieren? Im Runnable?

 

[Louis2]

Dieses Problem besteht immer noch, habe verschiedene Varianten mit dem boolean probiert aber das Versenden bzw. der Fortschrittsbalken wird nicht angehalten.

Hmm noch Vorschläge?

 

[Louis2]

Das Problem besteht weiterhin. Ich verstehe es einfach nicht, das Versenden wird nie abgebrochen. Bin ich zu dumm oder ist die Lösung doch nicht so einfach wie ich es mir erhofft habe? ???:L
Wo ist mein fehler?

public void stop() 
{ 
    state = false;
}
    
public void start()
{
    t = new Thread(new Runnable()
    {
        public void run()
        {
            cancelButton.setEnabled(true);
            state = true;
            while (state)
            {
                try
                {
                    Transport.send(msg);
                }
                catch (Exception e4)
                {
                    JOptionPane.showMessageDialog(null, "Error during transport:" + "\n" + e4.getMessage(), "Message", JOptionPane.ERROR_MESSAGE);
                }
                j=k;
                                    
                SwingUtilities.invokeLater(new Runnable()
                {
                    public void run()
                    {
                        bar.setValue(j);
                        valueProg.setText((j) + " of " + leng + " Emails");
                    }
                });
                if (action == cancelButton) // hier sollte er abbrechen/stoppen oder?
                    stop();
            }
        } 
    });
    t.start();
}

 

[Mag1c]

Hi,

wie sieht denn dein ActionListener aus ? Hast du einen gemeinsamen für Start/Stop ? Das if (action == cancelButton) muß jedenfalls in den ActionListener.

Gruß
Mag1c

 

[Bleiglanz]

stop nicht verwenden

wenn dann interrupt für den Thread aufrufen, und zwar in der actionPerformed Methode des buttens

aber dazu musst du erstmal die anonyme innere klasse rausschmeissen, sonst hast du überhaupt keine Chance dem Thread was mitzuteilen (du willst ja den invokeLater anhalten, nicht den aussenrum)??

und wozu hast du eigentlich ZWEI Threads im einsatz?

 

[Louis2]

Zur Übersicht... so sieht das ganze aus (mit paar Änderungen), also
@Mag1c:

if (e.getSource() == cancelButton)

ist also im ActionListener drin, oder ???:L
@Bleiglanz: Statt stop() habe ich jetzt t.isInterrupted() genommen, das 2te

public void run()

habe ich rausgehauen. Maisl werden versendet, dazu habe ich ein Forschrittsbalken, welches in

  SwingUtilities.invokeLater(new Runnable()

aktualisiert wird. Bei abbrechen, muss natürlich der Balken stehen bleiben (da ich später Wiederaufsetzen implementieren möchte) aberder Versand der mails muss natürlich
auch abgebrochen werden (bzw. eingeschläfert) werden.
Was mache ich noch falsch?

.
.
public void actionPerformed(ActionEvent e) 
{
    .
    .
    validMailAddressSender(erg);
    .
}

boolean validMailAddressSender(String mailAddress) 
{
    .
    .
    writeMail_Log();
    .
}

public void writeMail_Log() 
{
    .
    .
    sendMail_Log();
    .
}

public void sendMail_Log() 
{
    .
    .
    start();
    .
}

public void start() 
{ 
    t = new Thread(new Runnable() 
    { 
        public void run() 
        { 
            cancelButton.setEnabled(true); 
            state = true; 
            while (state) 
            { 
                try 
                { 
                    Transport.send(msg); 
                } 
                catch (Exception e4) 
                { 
                    JOptionPane.showMessageDialog(null, "Error during transport:" + "\n" + 
e4.getMessage(), "Message", JOptionPane.ERROR_MESSAGE); 
                } 
                j=k; 
                                    
                SwingUtilities.invokeLater(new Runnable() 
                { 
                    bar.setValue(j); 
                    valueProg.setText((j) + " of " + leng + " Emails"); 
                }); 
                if (e.getSource() == cancelButton) // hier sollte er abbrechen/stoppen oder? 
                    t.isInterrupted();
            } 
        } 
    }); 
    t.start(); 
}

 

[Mag1c]

Hi,

oh, da hab ich mich wohl nicht so klar ausgedrückt. Also zeig mal bitte die ganze actionPerformed(...). Da muß nämlich auch das "if (e.getSource() == cancelButton)" rein. Das mit dem stop() war wohl ein Missverständnis. Du solltest deine eigenen Methoden nicht start() und stop() nennen (sondern z.B. startSendMail() und stopSendMail()).

Gruß
Mag1c

 

[Louis2]

@Mag1c: Nabend ,
also wie du oben im Beispiel sehen kannst, gibt es die actionPerformed() Methode und dadrin sind die anderen sozusagen "gekapselt".
Wie gesagt abgebrochen muss das "Senden" (Transfer.send(msg)) und Fortschrittsbalken (in SwingUtilities.invokeLater).

Die actionPerformed() wie gewünscht: (muss ich "if (e.getSource() == cancelButton)" nach dem Methode Aufruf reinpacken??)

public void actionPerformed(ActionEvent e) 
{
    selectedColumns = table.getSelectedColumns();
    leng = table.getRowCount();
    action=e.getSource();
                           
    if ((main.LogSchalter.equals("NO") | main.LogSchalter.equals("No") | 
main.LogSchalter.equals("no")) && (main.DataAttached.equals("NO") | 
main.DataAttached.equals("No") | main.DataAttached.equals("no") | 
main.DataAttached.equals("") | main.DataAttached.equals("YES") | 
main.DataAttached.equals("Yes") | main.DataAttached.equals("yes")))
    {
        if (action == sendButton) 
        { 
            number = 0;
            check = 0;
            check1 = 0;
            check2 = 0;
            check3 = 0;
            check4 = 0;
            for (i=0;i<leng;i++)
            {
                String erg = (String) table.getModel().getValueAt(i, 2);
                if (erg == null)
                    number++;
                else
                    validMailAddressRecipient(erg); // Methode wird aufgerufen
            }
            if (number>0)
                JOptionPane.showMessageDialog(null, "No recipient address in one or more record(s) available, please check!", "Message", 
JOptionPane.INFORMATION_MESSAGE); 
            else if (check>0 || check1>0 || check2>0 || check3>0 || check4>0)
                JOptionPane.showMessageDialog(null, "One or more recipient address(es) do(es) not have the right syntax, please check!", 
"Message", JOptionPane.INFORMATION_MESSAGE);
            else if (main.INIEmailFrom.equals(""))
                JOptionPane.showMessageDialog(null, "No sender registered, please check!", 
"Message", JOptionPane.INFORMATION_MESSAGE);
            else
            {
                validMailAddressSender(main.INIEmailFrom); // Methode wird aufgerufen
            }
        }
    }
    else
    {
        if (e.getSource() == sendButton) 
       {
           JOptionPane.showMessageDialog(null, "Illegal input in .ini (LogOnly OR FileAttached), please check!", "Message", 
JOptionPane.INFORMATION_MESSAGE); 
        }  
    }
}

 

[Mag1c]

Hi,

vom Prinzip her funktioniert das mit dem cancelButton genauso wie mit dem sendButton. D.h. wenn der cancelButton enabled wurde und du da drauf geklickt hast, wird ganz genauso die actionPerformed(...)-Methode aufgerufen. Du solltest auch in der actionPerformed(...) zuerst die Quelle selektieren (es sei denn, du willst bestimmte Bedingungen für alle Events gleich prüfen). Hier also mal ein paar Code-Schnipsel, die dich hoffentlich etwas weiterbringen:

public void actionPerformed(ActionEvent e) 
{ 
    selectedColumns = table.getSelectedColumns(); 
    leng = table.getRowCount(); 
    action=e.getSource();

    if (action == sendButton)
    {
        if ((main.LogSchalter ...

    }
    else if (action == cancelButton)
    {
        stopSendingMail();
    }
}


public void stopSendingMail ()
{
    state = false;
}

Und noch ein Tip: main.LogSchalter.equalsIgnoreCase("no")

Gruß
Mag1c

 

[Louis2]

Hallo,

funktioniert immer noch nicht, irgendwo ist der Wurm drin. Irgendwie wird die Aktion des Buttons nicht in der richtigen Methode aufgerufen/ausgeführt.
Die "state" Überprüfung erfolgt in der writeMail_Log() Methode die irgendwann die sendMail_Log() aufruft.
Bei der writeMail_Log() wird in eine Log Datei geschrieben, aber wenn dort die Überprüfung vorgenommen wird, sollte er beim Klick des Buttons auch abbrechen, nichts passiert ;-) Eine Ahnung? (Die ganze Klasse zu posten ist ein bisschen zu lang, kann sie auch schicken wenn Bedarf ist).

Meine actionPerformed:

public void actionPerformed(ActionEvent e) 
{
    selectedColumns = table.getSelectedColumns();
    leng = table.getRowCount();
    action=e.getSource();
                           
        if ((main.LogSchalter.equalsIgnoreCase("no")) && (main.DataAttached.equalsIgnoreCase("no") | main.DataAttached.equals("") | main.DataAttached.equalsIgnoreCase("yes")))
        {
            if (action == sendButton) 
            { 
                .
                if (number>0)
                .
                else
                {
                    validMailAddressSender(main.INIEmailFrom);
                }            
            }
            if (action == cancelButton)
            {
                stopSendingMail();
            }
        }
        else if ((main.LogSchalter.equalsIgnoreCase("yes") | main.LogSchalter.equals("")) && (main.DataAttached.equalsIgnoreCase("no") | main.DataAttached.equals("") | main.DataAttached.equalsIgnoreCase("yes"))) 
        {
            if (action == sendButton) 
            { 
                .
                if (number>0)
                .    
                else
                {
                    validMailAddressSender(main.INIEmailFrom);
                }
            }
            if (action == cancelButton)
            {
                stopSendingMail();
            }
        }
}

Die stopSendingMail():

public void stopSendingMail() 
{ 
    state = false; 
    t.isInterrupted();
}

Die validMailAddressSender():

boolean validMailAddressSender(String mailAddress) 
{ 
    .
    if (question == JOptionPane.YES_OPTION)
    {
        if ((main.LogSchalter.equalsIgnoreCase("yes") | main.LogSchalter.equals("")) && (main.DataAttached.equalsIgnoreCase("no") | main.DataAttached.equals("") | main.DataAttached.equalsIgnoreCase("yes"))) 
                    writeLog();
        else if ((main.LogSchalter.equalsIgnoreCase("no")) && (main.DataAttached.equalsIgnoreCase("no") | main.DataAttached.equals("") | main.DataAttached.equalsIgnoreCase("yes")))
                    writeMail_Log();
     }
     return retValue;
}

Die writeMail_Log():

public void writeMail_Log() // Write in Email body and log
{
    .
    if (ret == JOptionPane.YES_OPTION) 
    {
        sendButton.setEnabled(true);
        cancelButton.setEnabled(false);            
        try
        {
            dateiStream = new FileWriter(logname); 
            ausgabe = new PrintWriter(dateiStream);
            dateiStream1 = new FileWriter(filename); 
            csvdata = new PrintWriter(dateiStream1);
                
            while (state == true)
            {
                cancelButton.setEnabled(true);
                sendButton.setEnabled(false);
                    
                for (k=0; k<leng; k++)
                {
                    try
                    {
                        .
                        for (int y=0; y<=selectedColumns.length-1;y++)
                        {
                            .
                        }                            
                        sendMail_Log();
                    }
                    catch (Exception e6)
                    {
                        . 
                    }
                    main.setVisible(false);
                }
                ausgabe.close();
                state = false;
            }
        }    
        catch (Exception e7)
        {
            . 
        }
    }

Die sendMail_Log():

public void sendMail_Log() // Send Email and log
{
   .
   .
   //Runnable r = new Runnable()
   t = new Thread(new Runnable() 
   {
       public void run()
       {
           try
           {
               Transport.send(msg);
           }
           catch (Exception e4)
           {
               .
           }
           j=k;
                                    
           SwingUtilities.invokeLater(new Runnable()
           {
               public void run()
               {
                   bar.setValue(j);
                   valueProg.setText((j) + " of " + leng + " Emails");
               }
           });
        }
   });
   //};
   //Thread t = new Thread(r);
   t.start();
}

 

[Mag1c]

Hi,

na so langsam kommen wir der Sache doch näher Das t.isInterrupted() im stopSendingMail() kannst du weglassen.
Bei dem Rest hat sich der Code irgendwie seit dem Anfang verändert. Du hast jetzt die for-Schleife außerhalb der/des Threads. Damit erzeugst du für jede zu verschickende Mail einen neuen Thread. Das wolltest du so bestimmt nicht, oder?

(Falls du kein Problem damit hast, kannst du mir die Klasse auch mal per Mail schicken an Mag1c (at) gmx (dot) de
das würde die Lösungsfindung erheblich beschleunigen)

Gruß
Mag1c

 

[Mag1c]

Hi,

so, hab das nun mal kurz überflogen und im Prinzip ist auch klar, was da passieren soll

da ich gerade nicht soo viel Zeit habe, deinen Code umzubauen, versuche ich mal kurz den Ablauf darzustellen:

public void actionPerformed(ActionEvent e) {
    action=e.getSource();

    if (action == sendButton) {
        // Hier alles für den Send-Button rein
    }
    else if (action == cancelButton) {
        stopSendingMail();
    }
}

public void stopSendingMail() { 
    state = false; 
}

public void writeMail_Log () {
    ...
    cancelButton.setEnabled(true);
    t = new Thread(new Runnable() 
    {
        public void run() {
            for (k=0; k < leng && state == true; k++) {
                ...
                // Mail senden
                // und Scrollbalken aktualisieren
            }
        }
    }

D.h. du erzeugst EINEN Thread der nacheinander ALLE Mails rausschickt. In der Hauptschleife des Threads (for k=0...) wird auch die Abbruchbedingung (state == true) geprüft. D.h. drückst du auf den cancelButton, wird das Flag auf false gesetzt. Wenn der Thread mit dem senden der aktuellen Mail fertig ist, bricht er den weitern Mail-Versand ab.

Gruß
Mag1c

 

[Louis2]

Hallo,

also das mit dem Abbruch funktioniert schonmal, auch die JProgressBar wird gestoppt. Aber:
1. Die Excel-Datei die auch produziert wird, wird nicht mehr aktualisiert sondern beinhaltet immer den Wert der ersten mail (Vorgang unter writeMail_Log()). Ist aber seltsam ich schliesse ja die csv.Datei nach jedem Durchgang (Zeile 52) Dass der Name der Datei immer gleich ist, sollte doch auch kein Problem sein oder kann er doch die alte nicht überschreiben??
2. Nun möchte ich das Wiederaufsetzen implementieren. Heißt wenn abgebrochen bekommt das Button die Schrift "Wiederaufsetzen", beim Knopfdruck wechselt der Status wieder auf true und sollte weitergemacht werden. D.h im Klartext wie kann ich zu 100% wissen wo der Sendevorgang abgebrochen wurde. Die einfachste Variante wäre die Zahl bei der JProgressBar zu nehmen und in eine For-Schleife von dort bis zum Ende das ganze Sende-Vorgang weiterzumachen. Gibt es ne andere einfachere Lösung?

public void writeMail_Log() // Write in Email body and log
{
        final String ans = JOptionPane.showInputDialog(this, "Email subject title", "Email subject", JOptionPane.INFORMATION_MESSAGE);
        String fname = JOptionPane.showInputDialog(this, "Excel file name title", "Excel file name", JOptionPane.INFORMATION_MESSAGE); 
        filename = main.AttachLocation + fname + ".csv";
        .
        if (ret == JOptionPane.YES_OPTION) 
        {
            sendButton.setEnabled(true);
            cancelButton.setEnabled(false);            
            try
            {
                dateiStream = new FileWriter(logname); 
                ausgabe = new PrintWriter(dateiStream);
                dateiStream1 = new FileWriter(filename); 
                csvdata = new PrintWriter(dateiStream1);
                
                cancelButton.setEnabled(true);
                sendButton.setEnabled(false);
                t = new Thread(new Runnable() 
                { 
                    public void run() 
                    {    
                    for (k=0; k<leng && state == true; k++)
                    {
                    try
                    {
                        htmltable="<html><body><table border='1' cellpadding='0' cellspacing='0'>";
                        htmltable=htmltable + "<tr>";
                        for (int y=0; y<=selectedColumns.length-1;y++)
                        {
                            htmltable=htmltable + "<td width='175px'><div align='left'>[b]" + table.getColumnName(selectedColumns[y]) + "[/b]</div></td>";
                            csvdata.print(table.getColumnName(selectedColumns[y]) + ";");
                        }
                        htmltable=htmltable + "</tr><tr>";
                        csvdata.println(System.getProperty("line.separator"));                            
                        for (int y=0; y<=selectedColumns.length-1;y++)
                        {
                            main.appendSubject(ans);
                            yourValue = table.getModel().getValueAt(k, selectedColumns[y]); 
                            if (yourValue == null)
                                htmltable=htmltable+ "<td width='175px'><div align='left'>" + "" + "</div></td>";
                            else 
                                htmltable=htmltable+ "<td width='175px'><div align='left'>" + yourValue + "</div></td>";
                                
                            main.appendText(table.getColumnName(selectedColumns[y]) + ": " + yourValue + System.getProperty("line.separator"));
                            
                            Object CSVValue = table.getModel().getValueAt(k, selectedColumns[y]); 
                            csvdata.print(CSVValue + ";");
                        }                            
                        csvdata.close(); // Schliessen der .csv Datei
                        main.appendText(System.getProperty("line.separator"));
                        htmltable=htmltable + "</tr></table></body></html>";
                        
                        main.appendToEmail(getWert(k));
                                                                               
                        sendMail_Log();
                    }
                    catch (Exception e6)
                    {
                        JOptionPane.showMessageDialog(null, "Error: " + "\n" + e6.getMessage(), "Message", JOptionPane.ERROR_MESSAGE);
                    }
                    main.setVisible(false);
                }
                ausgabe.close();
                    }
                });
                t.start();
            }
            catch (Exception e7)
            {
                JOptionPane.showMessageDialog(null, "Error: Could not create file", "Message", JOptionPane.ERROR_MESSAGE); 
            }
      }
}

public void sendMail_Log() // Send Email and log
{
        Properties props=new Properties();
        if (main.INIHost != null)
            props.put("mail.smtp.host", main.INIHost);
                                            
        Session mailConnection=Session.getInstance(props,null);
        msg=new MimeMessage(mailConnection);
        
        try
        {
            if (main.INIEmailToBCC.equals(""))
            {
                to=new InternetAddress(main.toField.getText());
                from=new InternetAddress(main.INIEmailFrom);
            }    
            else
            {
                to=new InternetAddress(main.toField.getText());
                bcc=new InternetAddress(main.INIEmailToBCC);
                from=new InternetAddress(main.INIEmailFrom); 
                msg.setRecipient(Message.RecipientType.BCC, bcc);
            }
                 
            MimeBodyPart mbp1 = new MimeBodyPart();
            mbp1.setContent(htmltable,"text/html; charset=ISO-8859-1");
            
            if (main.DataAttached.equalsIgnoreCase("no") | main.DataAttached.equals(""))
            {
                mp = new MimeMultipart();
                mp.addBodyPart(mbp1);
                
                currentDate = new java.util.Date();                 
                ausgabe.println("Mail" + (k+1) + " / " + currentDate + 
System.getProperty("line.separator") + "Host: " + 
main.hostField.getText() + " / " + "From: " + 
main.fromField.getText() + " / " + "To: " + 
main.toField.getText() + " / " + "BCC: " + 
main.toBCCField.getText() + " / " + "Subject: " + 
main.subjectField.getText() + System.getProperty("line.separator") + 
"Attached: -----" + System.getProperty("line.separator") + 
main.message.getText() + System.getProperty("line.separator")); 
            }
            else if (main.DataAttached.equalsIgnoreCase("yes"))
            {
                MimeBodyPart mbp2 = new MimeBodyPart();
                FileDataSource fds = new FileDataSource(filename);
                mbp2.setDataHandler(new DataHandler(fds));
                mbp2.setFileName(fds.getName());
            
                mp = new MimeMultipart();
                mp.addBodyPart(mbp1);
                mp.addBodyPart(mbp2);
                
                currentDate = new java.util.Date();                 
                if (main.AttachLocation.equals(""))
                    ausgabe.println("Mail" + (k+1) + " / " + currentDate + 
System.getProperty("line.separator") + "Host: " + main.hostField.getText() + 
" / " + "From: " + main.fromField.getText() + " / " + "To: " + 
main.toField.getText() + " / " + "BCC: " + main.toBCCField.getText() + 
" / " + "Subject: " + main.subjectField.getText() + System.getProperty("line.separator") + 
"Attached: " + main.getApplicationPath() + "\\" + filename + 
System.getProperty("line.separator") + main.message.getText() + 
System.getProperty("line.separator")); 
            }
                                        
            msg.setContent(mp);
            msg.setFrom(from);
            msg.setRecipient(Message.RecipientType.TO, to);
            msg.setSubject(main.subjectField.getText());
                                                                         
                    try
                    {
                        Transport.send(msg);
                    }
                    catch (Exception e4)
                    {
                        JOptionPane.showMessageDialog(null, "Error during transport:" + "\n" + e4.getMessage(), "Message", JOptionPane.ERROR_MESSAGE);
                    }
                    j=k+1;
                                    
                    SwingUtilities.invokeLater(new Runnable()
                    {
                        public void run()
                        {
                            bar.setValue(j);
                            valueProg.setText((j) + " of " + leng + " Emails");
                        }
                    });
                                                                                                                         
            main.message.setText("");
            main.subjectField.setText("");
        }
        catch (Exception e5)
        {
            JOptionPane.showMessageDialog(null, "Error during transport:" + "\n" + e5.getMessage(), "Message", JOptionPane.ERROR_MESSAGE);
        }
    }

 

[Mag1c]

Hi,

zu 1.) genau das ist der Grund, warum dort nur der erste Eintrag drin steht. Du schließt csvdata innerhalb der Schleife und öffnest es nicht wieder. Verschiebe das Schließen bis nach dem Ende der for-Schleife.

zu 2.) Ich empfehle dir dringend, mal ein Refactoring zu machen, funktionale Einheiten zu bilden und in eigene Klassen auszulagern, die Verwendung von globalen Variablen zu reduzieren. Mit einer klareren Strukturierung wirst du auch selbst besser damit zurecht kommen.

Gruß
Mag1c

 

[Louis2]

Hallo,

zu 1) Ich wollte nicht alles in 1 Datei packen wie beim Log sondern einzeln... habe ich anders gelöst.
zu 2 und das Wiederaufsetzen nach dem Abbrechen) Also in der API steht "It is never legal to start a thread more than once. In particular, a thread may not be restarted once it has completed execution." also muss ich mein Thread erstmal beenden bevor ich mit dem Wiederaufsetzen beginne.
So ich habe schonmal raus bei welcher Position das Wiederaufsetzen beginnen soll, bei welche Zeile in der JTable die Infos wieder geholt werden müssen.
Mein Problem ist einfach, dass beim Wiederaufsetzen nichts passiert ;-) Nur eine leer Log Datei wird geöffnet, ich habe es auch mit t.stop() probiert geht nicht, weiss jemand warum? Ich lade ja nur eine Methode... (die selbe wie immer --> also liegt es wohl am Thread der gerade läuft?)

if (action == cancelButton)
{
    if (state == true) // Wenn Senden läuft, Status True
    {
        stopSendingMail();
        cancelButton.setText("Continue?");
    }
    else if (state == false) // Wenn Senden abgebrochen, Status False
    {
        cancelButton.setText("Cancel");
        int nextValue = bar.getValue();
        start=nextValue;
        time = formatter.format(new java.util.Date());
        logname = main.LogLocation + "Log" + time + ".txt";
        t.stop(); // Thread von vorher beenden
        writeMail_Log(); // Methode nochmal laden
     }
}

public void writeMail_Log() // Write in Email body and log
{
    try
    {
        dateiStream = new FileWriter(logname); 
        ausgabe = new PrintWriter(dateiStream);
                                
        cancelButton.setEnabled(true);
        sendButton.setEnabled(false);
        t = new Thread(new Runnable() 
        { 
            public void run() 
            {                   
                for (k=start; k<leng && state == true; k++) // Infos werden ab k=start Wert geholt (siehe oben)
                {
                    try
                    {
                        dateiStream1 = new FileWriter(filename); 
                        csvdata = new PrintWriter(dateiStream1);
                        htmltable="<html><body><table border='1' cellpadding='0' cellspacing='0'>";
                        htmltable=htmltable + "<tr>";
                        for (int y=0; y<=selectedColumns.length-1;y++)
                        {
                            htmltable=htmltable + "<td width='175px'><div align='left'>[b]" + table.getColumnName(selectedColumns[y]) + "[/b]</div></td>";
                            csvdata.print(table.getColumnName(selectedColumns[y]) + ";");
                        }
                        htmltable=htmltable + "</tr><tr>";
                        csvdata.println(System.getProperty("line.separator"));                            
                        for (int y=0; y<=selectedColumns.length-1;y++)
                        {
                            main.appendSubject(ans);
                            yourValue = table.getModel().getValueAt(k, selectedColumns[y]); 
                            if (yourValue == null)
                                htmltable=htmltable+ "<td width='175px'><div align='left'>" + "" + "</div></td>";
                            else 
                                htmltable=htmltable+ "<td width='175px'><div align='left'>" + yourValue + "</div></td>";
                                
                            main.appendText(table.getColumnName(selectedColumns[y]) + ": " + yourValue + System.getProperty("line.separator"));
                            
                            Object CSVValue = table.getModel().getValueAt(k, selectedColumns[y]); 
                                csvdata.print(CSVValue + ";");
                        }                            
                        csvdata.close();
                        main.appendText(System.getProperty("line.separator"));
                        htmltable=htmltable + "</tr></table></body></html>";

                        main.appendToEmail(getWert(k));
                                                                               
                        sendMail_Log();
                    }
                    catch (Exception e6)
                    {
                        JOptionPane.showMessageDialog(null, "Error: " + "\n" + e6.getMessage(), "Message", JOptionPane.ERROR_MESSAGE);
                    }
                    main.setVisible(false);
                }
                ausgabe.close();
            }
       });
       t.start();

    }
    catch (Exception e7)
    {
        JOptionPane.showMessageDialog(null, "Error: Could not create file", "Message", JOptionPane.ERROR_MESSAGE); 
    }
}

 

[Mag1c]

Hi,

du mußt den Thread nicht stoppen, da dieser sich selbst beendet, wenn du state auf false setzt. Du mußt allerdings, bevor du den nächsten Thread startest, state wieder auf true setzten, da sich sonst der neue Thread auch wieder gleich beendet.

Gruß
Mag1c

 

[Louis2]

Darauf hätte ich auch selber kommen können *schwach*
Naja danke für alles !!