SwingWorkerのパラメータを更新する

Question

私はいくつかの助けが必要です。私はファイルマネージャのようなプログラムを作っています。私のプログラムでは、同時にファイルをコピーする必要があります。そのため私はを使ってコピーの進捗状況をJProgressbarで確認していますが、同じ宛先のタスクのコピーにファイルを追加する方法を知る必要があります。

これは私の主要なプログラムでSwingworkerから拡張された私のクラスです。私は1つの宛先でコピーするファイルやフォルダを選択します。 Copytaskが動作している間に必要なのは、Copyitem Arraylistにファイルを追加することができます。

私の英語については助けてください。ここで

import java.awt.Dimension; 
import java.awt.Toolkit; 
import java.io.File; 
import java.io.FileInputStream; 
import java.io.FileOutputStream; 
import java.io.IOException; 
import java.io.OutputStream; 
import java.util.ArrayList; 
import java.util.List; 
import javax.swing.JDialog; 
import javax.swing.JOptionPane; 
import javax.swing.JProgressBar; 
import javax.swing.SwingWorker; 
import xray.XRAYView; 


public class CopyTask extends SwingWorker<Void, Integer> 
    { 

     ArrayList<CopyItem>copia; 
     private long totalBytes = 0L; 
     private long copiedBytes = 0L; 
     JProgressBar progressAll; 
     JProgressBar progressCurrent; 
     boolean override=true; 
     boolean overrideall=false; 


     public CopyTask(ArrayList<CopyItem>copia,JProgressBar progressAll,JProgressBar progressCurrent) 
     { 

      this.copia=copia; 
      this.progressAll=progressAll; 
      this.progressCurrent=progressCurrent; 


      progressAll.setValue(0); 
      progressCurrent.setValue(0); 
      totalBytes=retrieveTotalBytes(copia); 

     } 

     public void AgregarCopia(ArrayList<CopyItem>addcopia)throws Exception{ 

      copia.addAll(copia.size(), addcopia); 
      totalBytes=retrieveTotalBytes(addcopia)+totalBytes; 
      System.out.println("AL AGREGAR: "+copia.size()+" Tamaño"+totalBytes); 



     } 

     public File getDriveDest(){ 
     File dest=new File(copia.get(0).getOrigen().getPath().split("\\")[0]); 
     return dest; 
     } 


     @Override 
     public Void doInBackground() throws Exception 
     { 


      for(CopyItem cop:copia){ 

      File ori=cop.getOrigen(); 
      File des=new File(cop.getDestino().getPath()); 
      if(!des.exists()){ 
       des.mkdirs(); 
      } 
      if(!overrideall){ 
      override =true; 
      } 
      File para=new File(cop.getDestino().getPath()+"\\"+ori.getName()); 
      copyFiles(ori, para); 

      } 
      return null; 
     } 

     @Override 
     public void process(List<Integer> chunks) 
     { 
      for(int i : chunks) 
      { 
       progressCurrent.setValue(i); 


      } 
     } 

     @Override 
     public void done() 
     { 
      setProgress(100); 

     } 

     private long retrieveTotalBytes(ArrayList<CopyItem>fich) 
     { 
      long size=0; 
      for(CopyItem cop: fich) 
      { 
       size += cop.getOrigen().length(); 

      } 

      return size; 
     } 






private void copyFiles(File sourceFile, File targetFile) throws IOException 

     { 
        if(overrideall==false){ 
         if(targetFile.exists() && !targetFile.isDirectory()){ 

          String []options={"Si a Todos","Si","No a Ninguno","No"}; 
          int seleccion=JOptionPane.showOptionDialog(null, "El fichero \n"+targetFile+" \n se encuentra en el equipo, \n¿Desea sobreescribirlo?", "Colisión de ficheros", JOptionPane.DEFAULT_OPTION, JOptionPane.WARNING_MESSAGE, null, options, null); 

          switch(seleccion){ 
           case 0: 
           override=true; 
           overrideall=true; 
           break; 
           case 1: 
           override=true; 
           overrideall=false; 
           break; 
           case 2: 
           override =false; 
           overrideall=true; 
           break; 
           case 3: 
           override =false; 
           overrideall=false; 
           break; 

          } 

         } 

        } 

        if(override || !targetFile.exists()){ 
        FileInputStream LeeOrigen= new FileInputStream(sourceFile); 

        OutputStream Salida = new FileOutputStream(targetFile); 

        byte[] buffer = new byte[1024]; 
        int tamaño; 

        long fileBytes = sourceFile.length(); 

        long totalBytesCopied = 0; 

        while ((tamaño = LeeOrigen.read(buffer)) > 0) { 

        Salida.write(buffer, 0, tamaño); 

        totalBytesCopied += tamaño; 
        copiedBytes+= tamaño; 

        setProgress((int)Math.round(((double)copiedBytes++/(double)totalBytes) * 100)); 

        int progress = (int)Math.round(((double)totalBytesCopied/(double)fileBytes) * 100); 

        publish(progress); 



        } 


        Salida.close(); 
        LeeOrigen.close(); 



       publish(100); 
       } 


      } 
     } 

がCopyItemクラスは

import java.io.File; 


public class CopyItem { 
    File origen; 
    File destino; 
    String root; 

    public CopyItem(File origen, File destino) { 
     this.origen = origen; 
     this.destino = destino; 
    } 

    public CopyItem(File origen, File destino, String root) { 
     this.origen = origen; 
     this.destino = destino; 
     this.root = root; 
    } 

    public String getRoot() { 
     return root; 
    } 

    public void setRoot(String root) { 
     this.root = root; 
    } 


    public File getOrigen() { 
     return origen; 
    } 

    public void setOrigen(File origen) { 
     this.origen = origen; 
    } 

    public File getDestino() { 
     return destino; 
    } 

    public void setDestino(File destino) { 
     this.destino = destino; 
    } 

    @Override 
    public String toString() { 
     return super.toString(); //To change body of generated methods, choose Tools | Templates. 
    } 


} 

Answer 1

ですはい、あなたは直接ソースリストにファイルを追加することができます（リストをコピーするファイルが含まれています）が、あなたはあなたのコードを同期させるために必要な複数のファイルを追加することになりますので、別の方法は、別のスレッド（UIスレッド）で、BlockingQueueを使用して実装することです。

コンシューマークラスは別のスレッドまたはSwingworkerコーディングファイルで実行されています。 ProducerクラスはUIスレッドを実行します（さらにファイルを選択します）。

BlockingQueueにアクセスする必要があります（もちろん、BlockingQueueの実装はドキュメントに基づいてスレッドセーフです）

スレッド実行を管理するためにスレッドプールを使用することをお勧めします（オプション）。