ProgressBar für Kopieraktion

[Eminent]

Hi,

hab leider mit der Suche nicht so recht was gefunden. Ich habe ne kleine Anwendung, die u . a. Dateien kopiert. Da man bei größeren Datein immer nicht so genau weiß wie weit der Kopiervorgang ist würde ich gern ne Progressbar verwenden um den Verlauf des Vorgangs darzustellen.

Leider hab ich keine Ahnung wie ich selber sehe wie weit der Kopiervorgang ist.

Ich verwende folgenden Code um Files zu kopieren (try-catch hab ich weg gelassen):

   private void copy(final File from, final File to) {      

         FileChannel in = new FileInputStream(from).getChannel();
         FileChannel out = new FileOutputStream(to).getChannel();
         
         out.transferFrom(in, 0, in.size());
         
         in.close();
         out.close();

   }

Gibts da irgend eine Möglichkeit für mich zu sehen wie weit er Kopiervorgang ist?

Danke euch schon mal für die Mühen

P.S.: Wenn es dann einfacher wäre könnte ich die Dateien auch mit BufferedStreams kopieren.

Eminent

 

[thE_29]

Jop gibt es !


Ich würde es so machen!! (lasse auch alle try/catch weg)

private JProgressBar jpBar = new JProgressBar(0,100);
private boolean calc_bar = true;

private void copy(final File from, final File to)
{
  new Thread(){
public void run()
{ 
   while(calc_bar)
   {
     long lMax = from.length(), lCurrent = to.length();
     double d = (double) lMax / lCurrent;   
     d = 100.0 / d;
     jpBar.setValue((int)d);
     jpBar.validate();
     jpBar.repaint();
    }
}}.start();
   //deine kopierdingens dann hier
   calc_bar = false;
}

Habs aber nicht getestet Nur hier reingetipselt :bae:

 

[Eminent]

Jop gibt es !


Ich würde es so machen!! (lasse auch alle try/catch weg)

private JProgressBar jpBar = new JProgressBar(0,100);
private boolean calc_bar = true;

private void copy(final File from, final File to)
{
  new Thread(){
public void run()
{ 
   while(calc_bar)
   {
     long lMax = from.length(), lCurrent = to.length();
     double d = (double) lMax / lCurrent;   
     d = 100.0 / d;
     jpBar.setValue((int)d);
     jpBar.validate();
     jpBar.repaint();
    }
}}.start();
   //deine kopierdingens dann hier
   calc_bar = false;
}

Habs aber nicht getestet Nur hier reingetipselt :bae:

OK, danke dir ich werd es dann gleich mal ausprobieren!

 

[thE_29]

Die Anzeige für den ProgressBar usw musst halt noch sorgen..

 

[Eminent]

Die Anzeige für den ProgressBar usw musst halt noch sorgen..

OK, hat wunderbar funktioniert. Um die Anzeige hab ich mich nicht weiter gekümmert, ich hab statt der JProgressbar dann einfach nen ProgressMonitor verwendet das ist um einiges einfacher!

Für die, die es interessiert, hier ist mein Code:

   private void copy(final File from, final File to) {
      // private ProgressMonitor _status; private boolean _bCalcBar;
      // _bCalcBar wird im Konstruktor bzw. init auf true gesetzt.
      _status = new ProgressMonitor(_view, "Kopiere Datei \"" + from.getName() + "\"",
         "copied ... ", 0, 100);

      new Thread() {
         public void run() {
            while (_bCalcBar) {
               long lMax = from.length(), lCurrent = to.length();
               double d = (double) lMax / lCurrent;
               d = 100.0 / d;
               _status.setProgress((int) d);
            }
         }
      }.start();

      try {
         FileChannel in = new FileInputStream(from).getChannel();
         FileChannel out = new FileOutputStream(to).getChannel();

         out.transferFrom(in, 0, in.size());

         in.close();
         out.close();

         SKGlobals.debug(from.getName() + " - erfolgreich kopiert.");
      } catch (FileNotFoundException fnfe) {
         SKGlobals.debug("CtReplicate - copy() - Datei nicht gefunden (" + from.getName() + ")");
         SKGlobals.debug(fnfe);
      } catch (IOException ioe) {
         SKGlobals.debug("CtReplicate - copy() - IOException (" + from.getName() + ")");
         SKGlobals.debug(ioe);
      }
      _bCalcBar = false;
   }

Danke nochmal thE_29

 

[Eminent]

Da war ich wohl n bisschen voreilig.

So lange ich nur eine Datei habe und das ganz so nur einmal aufrufe geht es ja wunderbar, nur wenn ich zwei Dateien nacheinander kopiere und meine copy-Methode ein zweites mal aufrufe funktioniert das ganze nicht mehr.
Dann bleibt der ProgressMonitor von der ersten Datei einfach stehen.

Hab ich in meinem Code was übersehen, oder muss ich da was anders machen? Hab leider auch nicht wirklich Ahnung von Threads :bahnhof:

 

[thE_29]

Ich teste mal!

 

[Mag1c]

Hi,

müsstest den Monitor auch schließen, wenn das Kopieren beendet ist.

besser wär natürlich, wenn du den ersten Monitor zurücksetzt und für weiteres Kopieren weiter verwendest.

Gruß
Mag1c

 

[Eminent]

Hi,

müsstest den Monitor auch schließen, wenn das Kopieren beendet ist.

besser wär natürlich, wenn du den ersten Monitor zurücksetzt und für weiteres Kopieren weiter verwendest.

Gruß
Mag1c

Schließen tut sich der Monitor selber. Der ProgressMonitor schließt sich, wenn er Max erreicht hat. Wie gesagt mit einer Datei geht es auch wunderbar! Monitor auf, Status anzeigen, wenn fertig Monitor zu und fertig.
Nur so bald eine zweite Datei kommt funzt es nicht mehr so schön. :cry:

 

[Mag1c]

Hi,

könnte eine "Race-Condition" sein. Du startest evtl. das zweite Kopieren, bevor der Update-Thread des ersten nochmal dran war und den Monitor geschlossen hat. Beim zweiten Start erzeugst du einen neuen Monitor und überschreibst damit die Variable _status, über die auch der erste Thread drauf zugreift.

Das ist erstmal eine reine Vermutung ... habe nix getestet.

Du könntest nun nach Beendigung des Kopiervorgangs auf das Ende des Threads warten (Thread#join).

Wie sieht es eigentlich mit der Systemlast aus ? Wäre es nicht sinnvoll, eine kurze Pause in den Update-Thread einzubauen ?

Gruß
Mag1c

 

[thE_29]

  private synchronized void copy(final File from, final File to) {
         // private ProgressMonitor _status; private boolean _bCalcBar;
         // _bCalcBar wird im Konstruktor bzw. init auf true gesetzt.
         _status = new ProgressMonitor(this, "Kopiere Datei \"" + from.getName() + "\"",
                                       "copied ... ", 0, 100);
         new Thread() {
            public synchronized void run() 
            {
              int last_stat = -1;
               while (_bCalcBar) {
                  long lMax = from.length(), lCurrent = to.length();
                  double d = (double) lMax / lCurrent;
                  d = 100.0 / d;
                  if(last_stat != d)
                  {
                    last_stat = (int) d;
                    if(_bCalcBar)
                      _status.setNote("copied " + last_stat + " %");
                    if(_bCalcBar)
                      _status.setProgress(last_stat);
                  }
               }
               if(_status != null)
                 _status.close();
               _status = null;
            }
         }.start();

         try {
           InputStream in = new FileInputStream(from);
           OutputStream out = new FileOutputStream(to);
           byte b[] = new byte[1];
           int x = 0; 
           while ( (x = in.read(b) ) != -1)
           {
             if(_status.isCanceled())
             {
               _bCalcBar = false;
               break;
             }
             out.write(b,0,x);
           }
           out.flush();
           in.close();
           out.close();
 
 
         } catch (FileNotFoundException fnfe) {
           fnfe.printStackTrace();
         } catch (IOException ioe) {
           ioe.printStackTrace();
         }
         if(_status != null)
           _status.close();
         _status = null;
         _bCalcBar = false;
      }

Das funktioniert bei mir!

Habe die Größe des byte Buffers auf 2 gesetzt, damit man auch bei kleinen Files etwas sieht!! Kann man halt beliebig (ich hab immer 1024) setzen!

 

[Eminent]

  private synchronized void copy(final File from, final File to) {
         // private ProgressMonitor _status; private boolean _bCalcBar;
         // _bCalcBar wird im Konstruktor bzw. init auf true gesetzt.
         _status = new ProgressMonitor(this, "Kopiere Datei \"" + from.getName() + "\"",
                                       "copied ... ", 0, 100);
         new Thread() {
            public synchronized void run() 
            {
              int last_stat = -1;
               while (_bCalcBar) {
                  long lMax = from.length(), lCurrent = to.length();
                  double d = (double) lMax / lCurrent;
                  d = 100.0 / d;
                  if(last_stat != d)
                  {
                    last_stat = (int) d;
                    if(_bCalcBar)
                      _status.setNote("copied " + last_stat + " %");
                    if(_bCalcBar)
                      _status.setProgress(last_stat);
                  }
               }
               if(_status != null)
                 _status.close();
               _status = null;
            }
         }.start();

         try {
           InputStream in = new FileInputStream(from);
           OutputStream out = new FileOutputStream(to);
           byte b[] = new byte[1];
           int x = 0; 
           while ( (x = in.read(b) ) != -1)
           {
             if(_status.isCanceled())
             {
               _bCalcBar = false;
               break;
             }
             out.write(b,0,x);
           }
           out.flush();
           in.close();
           out.close();
 
 
         } catch (FileNotFoundException fnfe) {
           fnfe.printStackTrace();
         } catch (IOException ioe) {
           ioe.printStackTrace();
         }
         if(_status != null)
           _status.close();
         _status = null;
         _bCalcBar = false;
      }

Das funktioniert bei mir!

Habe die Größe des byte Buffers auf 2 gesetzt, damit man auch bei kleinen Files etwas sieht!! Kann man halt beliebig (ich hab immer 1024) setzen!

Das Funktioniert bei mir leider auch nicht. Ich dachte dann ich stelle mal um (hab ja eigentlich mit FileChannel gearbeitet) auf Input- bzw. Outputstreams. Auch das ging nicht. Dann habe ich den Code von thE_29 1 zu 1 übernommen und er läuft in der Zeile: if(_status.isCanceled()) auf eine NullPointerException.

        InputStream in = new FileInputStream(from); 
        OutputStream out = new FileOutputStream(to); 
        byte b[] = new byte[4096]; 
        int x = 0; 
        while ( (x = in.read(b) ) != -1) 
        { 
          // NullPointer in nachfolgender Zeile
          if(_status.isCanceled()) 
          { 
            _bCalcBar = false; 
            break; 
          } 
          out.write(b,0,x); 
        } 
        out.flush(); 
        in.close(); 
        out.close();

Irgendwie läuft da bei mir was nicht so ganz richtig. Nur ich weiß nicht wo er das Problem hat. Denke mal es wird wohl irgendwie mit dem Ablauf vom Thread und dem eigentlichen Kopiervorgang zu tun haben.

 

[thE_29]

dann musst du anstatt der isCacnceld das hier

if(_status != null && _status.isCanceled())


reinmachen!

 

[Mag1c]

Hi Eminent,

ich würde mal bei deinem ursprünglichen Code bleiben. Sieht etwas sauberer aus

   private void copy(final File from, final File to) {
      // private ProgressMonitor _status; private boolean _bCalcBar;
      // _bCalcBar wird im Konstruktor bzw. init auf true gesetzt.
!     _bCalcBar = true;
      _status = new ProgressMonitor(_view, "Kopiere Datei \"" + from.getName() + "\"",
         "copied ... ", 0, 100);

!      Thread updater = new Thread() {
         public void run() {
            while (_bCalcBar) {
               long lMax = from.length(), lCurrent = to.length();
               double d = (double) lMax / lCurrent;
               d = 100.0 / d;
               _status.setProgress((int) d);
            }
!            _status.setProgress(100);      // Damit der Monitor sich wirklich schließt
         }
      };
!      updater.start();

      try {
         FileChannel in = new FileInputStream(from).getChannel();
         FileChannel out = new FileOutputStream(to).getChannel();

         out.transferFrom(in, 0, in.size());

         in.close();
         out.close();

         SKGlobals.debug(from.getName() + " - erfolgreich kopiert.");
      } catch (FileNotFoundException fnfe) {
         SKGlobals.debug("CtReplicate - copy() - Datei nicht gefunden (" + from.getName() + ")");
         SKGlobals.debug(fnfe);
      } catch (IOException ioe) {
         SKGlobals.debug("CtReplicate - copy() - IOException (" + from.getName() + ")");
         SKGlobals.debug(ioe);
      }
      _bCalcBar = false;
!     try {
!        updater.join();
!     } catch (InterruptedException ex) {}
   }

Ich habe meine Änderungen mit "!" markiert.

EDIT: wenn du copy merhfach nacheinander aufrufen willst, muß natürlich auch _bCalcBar jedesmal auf true gesetzt werden.

Gruß
Mag1c

 

[thE_29]

Ähm: 1. der FileChanel ist bockmist! Man kann den net abbrechen/abwürgen.. der schreibt seine bytes komme was wolle (außer reboot, nichtmal javaw beenden bringt was..)

2. Dein Problem das er mit dem File kopieren net fertig war und er somit er den Thread überschrieben hätten, bzw den _status geht gar net, da er den Aufruf schätze ich mal net in einem Thread macht...

Dh, nachdem der fertig kopiert ist, geht der erst aus der Methode copy raus und würde dann den nächsten copy Befehl ausführen!

Desweiteren sind meine Änderungen sehr wohl bedacht, den was bringt es dir zig 1000000mal den progressbar auf einen Wert zu setzen, wenn er sich gar net ändert??

4. warum setzt du ihn auf 100?? Okay, es is klar dass dann close aufegrufen wird, aber schöner ist einfach das close selber aufrufen ^^

5. Eine Abbruchmöglichkeit (weder auf den Button reagieren) noch einen wirklichen Abbruch (siehe 1) gewährleistet diese Methode auch nicht!!



@Threadersteller: wie genau sehen deine Probleme aus?? Siehst du nix, kopiert er nix, etc..

 

[Mag1c]

Hi thE_29, bleib doch mal ganz cool 8)

Ähm: 1. der FileChanel ist bockmist! Man kann den net abbrechen/abwürgen.. der schreibt seine bytes komme was wolle (außer reboot, nichtmal javaw beenden bringt was..)

Dazu kann ich nicht viel sagen, da ich das (a) nicht vorgeschlagen habe und (b) selbst noch nicht benutzt habe.

2. Dein Problem das er mit dem File kopieren net fertig war und er somit er den Thread überschrieben hätten, bzw den _status geht gar net, da er den Aufruf schätze ich mal net in einem Thread macht...

Dh, nachdem der fertig kopiert ist, geht der erst aus der Methode copy raus und würde dann den nächsten copy Befehl ausführen!

Habs nicht ausführlich erklärt. Es arbeiten zwei Threads, einer kopiert Datei einer aktualisiert ProgressBar. Klar ist der Kopierthread eher fertig und meine Idee war nun, daß der Kopierthread bereits erneut das copy aufgerufen hat um ein weiteres File zu kopieren, BEVOR der Updatethread mal wieder dran war. Habe gerade keine Idee, wie groß die Zeitscheibe bei Java für einzelne Threads ist.
Übrigens: nachdem ich festgestellt habe, daß die Flagvariable _bCalcBar nicht wieder auf true gesetzt wird, glaube ich an meine Vermutung selbst nicht mehr :bae:

4. warum setzt du ihn auf 100?? Okay, es is klar dass dann close aufegrufen wird, aber schöner ist einfach das close selber aufrufen ^^

Wenn der Kopierthread fertig ist, setzt er _bCalcBar auf false. Es ist durchaus möglich, daß der Updatethread aus der while-Schleife fliegt, bevor er das 100% gesetzt hat. Und ja, ein close()-Aufruf wäre natürlich logischer.

Generell ist es aber kein Allheilmittel, bei Problemen mit Threads einfach alles mit synchronized zuzupflastern. (zumal sie in diesem Fall wirkungslos sind)

Übrigens: JavaDoc zu FileChannel#transferFrom

* This method is potentially much more efficient than a simple loop
* that reads from the source channel and writes to this channel. Many
* operating systems can transfer bytes directly from the source channel
* into the filesystem cache without actually copying them.

und dann noch

* @throws AsynchronousCloseException
* If another thread closes either channel
* while the transfer is in progress

läßt vermuten, daß man den Vorgang sehr wohl unterbrechen kann.

Gruß
Mag1c

 

[thE_29]

Tjo..

Über die Methode!

Jedoch habe ich ein 600MB File kopiert, als Testzwecken!

Und siehe da, net mal wenn ich via dem Taskmaneger javaw abwürgen wollte hört der net auf.. Stattdesen war mein System unbrauchbar bis der fertig war...


Desweitern wo siehst du einen 2ten Thread??

Den eventdispatchter Thread oder welchen meinst du?

 

[Eminent]

Ähm: 1. der FileChanel ist bockmist! Man kann den net abbrechen/abwürgen.. der schreibt seine bytes komme was wolle (außer reboot, nichtmal javaw beenden bringt was..)

2. Dein Problem das er mit dem File kopieren net fertig war und er somit er den Thread überschrieben hätten, bzw den _status geht gar net, da er den Aufruf schätze ich mal net in einem Thread macht...

Dh, nachdem der fertig kopiert ist, geht der erst aus der Methode copy raus und würde dann den nächsten copy Befehl ausführen!

Desweiteren sind meine Änderungen sehr wohl bedacht, den was bringt es dir zig 1000000mal den progressbar auf einen Wert zu setzen, wenn er sich gar net ändert??

4. warum setzt du ihn auf 100?? Okay, es is klar dass dann close aufegrufen wird, aber schöner ist einfach das close selber aufrufen ^^

5. Eine Abbruchmöglichkeit (weder auf den Button reagieren) noch einen wirklichen Abbruch (siehe 1) gewährleistet diese Methode auch nicht!!



@Threadersteller: wie genau sehen deine Probleme aus?? Siehst du nix, kopiert er nix, etc..

Hi,

vorab schonmal, es geht!!!! :toll:

Mein Problem vorher war, dass er die erste Datei kopiert hatte und dann beim Beginn der zweiten auf eine NullPointerException gelaufen ist. Hat sich ja aber zum Glück erledigt.

Was FileChannel angeht ist das bei mir gar nicht schlecht, wenn sich der Kopiervorgang nicht abbrechen lässt. Ich benutze meine kleine Anwendung nämlich um Dateien zu archivieren, ich gleiche also zwei Pfade ab und kopiere dann von einem Pfad in einen Backuppfad. Und wenn er die Datei immer fertig kopiert ist das auch nicht schlecht.

Außerdem denke ich (es sieht zumindest für mich so aus), dass das Kopieren mit FileChannel schneller geht als mit Input- / OutputStreams.

Wie gesagt es funktioniert und ich danke euch für die umfangreiche und sofortige Hilfe!!! Vielen DANK!

Gruß
Eminent

Achja, hier jetzt der Code mit dem es bei mir geht (sind beide Möglichkeiten des Kopierens drin - FileChannel und Streams):

   private synchronized void copy(final File from, final File to) { 
      _bCalcBar = true;
      _status = new ProgressMonitor(_view, "Kopiere Datei \"" + from.getName() + "\"", 
         "copied ... ", 0, 100); 

      new Thread() { 
         public synchronized void run() { 
            int last_stat = -1; 
            while (_bCalcBar) { 
               long lMax = from.length(), lCurrent = to.length(); 
               double d = (double) lMax / lCurrent; 
               d = 100.0 / d; 
               if(last_stat != d) 
               { 
                 last_stat = (int) d; 
                 if(_bCalcBar && _status != null) {
                   _status.setNote("copied " + last_stat + " %"); 
                   _status.setProgress(last_stat); 
                 }
               } 
            } 
            if(_status != null) {
               _status.close(); 
            }
             _status = null; 
         } 
      }.start(); 

      try { 
         FileChannel in = new FileInputStream(from).getChannel(); 
         FileChannel out = new FileOutputStream(to).getChannel(); 

         out.transferFrom(in, 0, in.size()); 

         in.close(); 
         out.close(); 
      
//      try { 
//         BufferedInputStream in = new BufferedInputStream(new FileInputStream(from)); 
//         BufferedOutputStream out = new BufferedOutputStream(new FileOutputStream(to)); 
//         byte b[] = new byte[1024]; 
//         int x = 0; 
//         while ( (x = in.read(b) ) != -1) 
//         { 
//           if(_status != null && _status.isCanceled()) 
//           { 
//             _bCalcBar = false; 
//             break; 
//           } 
//           out.write(b,0,x); 
//         } 
//         out.flush(); 
//         in.close(); 
//         out.close();       

         SKGlobals.debug(from.getName() + " - erfolgreich kopiert."); 
      } catch (FileNotFoundException fnfe) { 
         SKGlobals.debug("CtReplicate - copy() - Datei nicht gefunden (" + from.getName() + ")"); 
         SKGlobals.debug(fnfe); 
      } catch (IOException ioe) { 
         SKGlobals.debug("CtReplicate - copy() - IOException (" + from.getName() + ")"); 
         SKGlobals.debug(ioe); 
      } 
      _bCalcBar = false; 
      if(_status != null) {
         _status.close(); 
      }
       _status = null; 
   }

 

[Mag1c]

Hi,

Jedoch habe ich ein 600MB File kopiert, als Testzwecken!

Und siehe da, net mal wenn ich via dem Taskmaneger javaw abwürgen wollte hört der net auf.. Stattdesen war mein System unbrauchbar bis der fertig war...

Aha, na wie gesagt, habe bisher FileChannel noch nicht benutzt.

Desweitern wo siehst du einen 2ten Thread??

Den eventdispatchter Thread oder welchen meinst du?

Jo, es gibt definitiv einen Thread, der die copy-Methode aufruft. Ob das der EventDispatch-Thread ist, weiß ich nicht (kenn ja den Code drumherum nicht). Wenn dann in copy(...) noch ein weiterer Thread gestartet wird, laufen zwei, einer führt das copy aus und einer aktualisiert den ProgressMonitor.

Gruß
Mag1c

 

[thE_29]

Asoo

Jo, dann wirst schon den gemeint haben (nehme mal an das er es von einem Button abhängig macht etc..)


@Eminent: Die Bufferd Streams sind sicher langsamer.. Ich hatte ja auch keinen BufferedInputStream, sondern nur InputStream...

 

[Eminent]

Asoo

Jo, dann wirst schon den gemeint haben (nehme mal an das er es von einem Button abhängig macht etc..)


@Eminent: Die Bufferd Streams sind sicher langsamer.. Ich hatte ja auch keinen BufferedInputStream, sondern nur InputStream...

Sorry, bin gestern nicht mehr dazu gekommen zu antworten. Nach meinen Erfahrungen sind Streams (ob buffered oder nicht) allgemein langsamer als FileChannel. Im Normalfall verwende ich eigentlich auch Streams, aber wenn ich größere Dateien habe ist FileChannel (finde ich) gar nicht so schlecht.

Aber auf jeden Fall nochmal DANKE für die Hilfe, ohne euch würde ich wahrscheinlich immer noch keine Lösung haben.

 

[thE_29]

*Häkchen setz*