Foro sobre Java SE > Cómo cancelar la tarea de SwingWorked?
Esto que sigue es lo que no entiendo:
botonCancela.addActionListener(e -> {
EventQueue.invokeLater(() -> {
new BackgroundWorker(botonAcciona, barra).cancel(true);
});
});
No es necesario usar el invokeLater en este contexto: la instancia de SwingWorker ya se ocupa de ejecutar en el EDT el código necesario.
Por otra parte, los ActionListener de Swing ya se ejecutan en el EDT.
¿Creas una nueva instancia de SwingWorker, para cancelarla inmediatamente?. Eso no tiene sentido. Lo que querrás será cancelar una ya creada y en ejecución.
new BackgroundWorker(botonAcciona, barra).execute();
Sin embargo, no asignas una propiedad a esa instancia, que es la que deberías usar en el ActionListener del botón de Cancelar.
// propiedades de la clase UIControl
private SwingWorker<Void,Void> worker;
// en el constructor
worker=new BackgroundWorker(botonAcciona, barra);
worker.execute();
botonCancela.addActionListener(e -> {
worker.cancel(true);
});
choces
Hola Buenas tardes a todos.
Tengo un problema con mi programa; estoy utilizado un swingworked para leer los registros de la base de datos y simular que lo carga con un JProgressBar.
Tengo un boton de inicio que hace la simulación de carga (Esto lo hace correctamente) y sin problemas.
Pero cuando intento detener el swingworked para que no siga con el ciclo de leer la informacion, no termina.
Se que un SwingWorked se cancela o termina con "swk.cancel(true);" pero no logro detenerlo.
Agredezco mucho su orientacion para lograr resolver mi problema.
Muchas gracias.
Este es mi código
import java.io.Serializable;
/**
* @author elalio
*
*/
public final class ControlEntradas implements Serializable {
/**
*
*/
public ControlEntradas() {
}
/**
* @param id_entrada
* @param id_usuario
* @param ip_maquina
* @param nombre_so
* @param version_k
* @param tipo
* @param version_jdk
* @param version_db
*/
public ControlEntradas(int id_entrada, int id_usuario,
String ip_maquina, String nombre_so, String version_k,
String tipo, String version_jdk, String version_db) {
this.id_entrada = id_entrada;
this.id_usuario = id_usuario;
this.ip_maquina = ip_maquina;
this.nombre_so = nombre_so;
this.version_k = version_k;
this.tipo = tipo;
this.version_jdk = version_jdk;
this.version_db = version_db;
}
/**
* @return the id_entrada
*/
public int getId_entrada() {
return id_entrada;
}
/**
* @param id_entrada the id_entrada to set
*/
public void setId_entrada(int id_entrada) {
this.id_entrada = id_entrada;
}
/**
* @return the id_usuario
*/
public int getId_usuario() {
return id_usuario;
}
/**
* @param id_usuario the id_usuario to set
*/
public void setId_usuario(int id_usuario) {
this.id_usuario = id_usuario;
}
/**
* @return the ip_maquina
*/
public String getIp_maquina() {
return ip_maquina;
}
/**
* @param ip_maquina the ip_maquina to set
*/
public void setIp_maquina(String ip_maquina) {
this.ip_maquina = ip_maquina;
}
/**
* @return the nombre_so
*/
public String getNombre_so() {
return nombre_so;
}
/**
* @param nombre_so the nombre_so to set
*/
public void setNombre_so(String nombre_so) {
this.nombre_so = nombre_so;
}
/**
* @return the version_k
*/
public String getVersion_k() {
return version_k;
}
/**
* @param version_k the version_k to set
*/
public void setVersion_k(String version_k) {
this.version_k = version_k;
}
/**
* @return the tipo
*/
public String getTipo() {
return tipo;
}
/**
* @param tipo the tipo to set
*/
public void setTipo(String tipo) {
this.tipo = tipo;
}
/**
* @return the version_jdk
*/
public String getVersion_jdk() {
return version_jdk;
}
/**
* @param version_jdk the version_jdk to set
*/
public void setVersion_jdk(String version_jdk) {
this.version_jdk = version_jdk;
}
/**
* @return the version_db
*/
public String getVersion_db() {
return version_db;
}
/**
* @param version_db the version_db to set
*/
public void setVersion_db(String version_db) {
this.version_db = version_db;
}
/* (non-Javadoc)
* @see java.lang.Object#hashCode()
*/
@Override
public int hashCode() {
final int prime = 31;
int result = 1;
result = prime * result + id_entrada;
result = prime * result + id_usuario;
result = prime * result + ((ip_maquina == null) ? 0 : ip_maquina.hashCode());
result = prime * result + ((nombre_so == null) ? 0 : nombre_so.hashCode());
result = prime * result + ((tipo == null) ? 0 : tipo.hashCode());
result = prime * result + ((version_db == null) ? 0 : version_db.hashCode());
result = prime * result + ((version_jdk == null) ? 0 : version_jdk.hashCode());
result = prime * result + ((version_k == null) ? 0 : version_k.hashCode());
return result;
}
/* (non-Javadoc)
* @see java.lang.Object#equals(java.lang.Object)
*/
@Override
public boolean equals(Object obj) {
if (this == obj) {
return true;
}
if (obj == null) {
return false;
}
if (!(obj instanceof ControlEntradas)) {
return false;
}
ControlEntradas other = (ControlEntradas) obj;
if (id_entrada != other.id_entrada) {
return false;
}
if (id_usuario != other.id_usuario) {
return false;
}
if (ip_maquina == null) {
if (other.ip_maquina != null) {
return false;
}
} else if (!ip_maquina.equals(other.ip_maquina)) {
return false;
}
if (nombre_so == null) {
if (other.nombre_so != null) {
return false;
}
} else if (!nombre_so.equals(other.nombre_so)) {
return false;
}
if (tipo == null) {
if (other.tipo != null) {
return false;
}
} else if (!tipo.equals(other.tipo)) {
return false;
}
if (version_db == null) {
if (other.version_db != null) {
return false;
}
} else if (!version_db.equals(other.version_db)) {
return false;
}
if (version_jdk == null) {
if (other.version_jdk != null) {
return false;
}
} else if (!version_jdk.equals(other.version_jdk)) {
return false;
}
if (version_k == null) {
if (other.version_k != null) {
return false;
}
} else if (!version_k.equals(other.version_k)) {
return false;
}
return true;
}
/**
*
*/
private static final long serialVersionUID = -1004110771863112909L;
private int id_entrada;
private int id_usuario;
private String ip_maquina;
private String nombre_so;
private String version_k;
private String tipo;
private String version_jdk;
private String version_db;
}
/**
* @author elalio
*
*/
public final class MuestraEntradas implements Serializable {
public static ArrayList<ControlEntradas> obtenEntradas() {
try {
listaControl = new ArrayList<>();
conx = ConectaDB.obtenerConexion();
pstm = conx.prepareStatement(CONSULTA);
result = pstm.executeQuery();
while (result.next()) {
id_entradas = result.getInt(1);
id_usuarios = result.getInt(2);
ip_maquinas = result.getString(3);
nombre_sos = result.getString(4);
version_ks = result.getString(5);
tipos = result.getString(6);
version_jdks = result.getString(7);
version_dbs = result.getString(8);
listaControl.add(new ControlEntradas(id_entradas, id_usuarios, ip_maquinas, nombre_sos, version_ks,
tipos, version_jdks, version_dbs));
}
if (!listaControl.isEmpty() && listaControl.size() != 0) {
System.out.println("La tabla tiene valores");
return listaControl;
} else {
System.out.println("No hay datos");
return null;
}
} catch (SQLException e) {
// TODO: handle exception
for (Throwable ex : e) {
System.out.printf("Error------------------->%s%n", ex.getLocalizedMessage());
}
return null;
} finally {
if (pstm != null) {
try {
pstm.close();
} catch (SQLException e) {
// TODO: handle exception
for (Throwable ex : e) {
System.out.printf("Error------------------->%s%n", ex.getLocalizedMessage());
}
}
}
if (result != null) {
try {
result.close();
} catch (SQLException e) {
// TODO: handle exception
for (Throwable ex : e) {
System.out.printf("Error------------------->%s%n", ex.getLocalizedMessage());
}
}
}
if (conx != null) {
ConectaDB.cerrarConexion(conx);
}
}
}
/**
*
*/
private static final long serialVersionUID = 3802376295249310174L;
private static Connection conx;
private static PreparedStatement pstm;
private static ResultSet result;
private static ArrayList<ControlEntradas> listaControl;
private static final String CONSULTA = "SELECT id_entrada,id_usuario,ip_maquina,"
+ "nombre_so,version_k,tipo,version_jdk,version_db FROM control_entradas";
private static int id_entradas;
private static int id_usuarios;
private static String ip_maquinas;
private static String nombre_sos;
private static String version_ks;
private static String tipos;
private static String version_jdks;
private static String version_dbs;
}
/**
* @author elalio
*
*/
public final class BackgroundWorker extends SwingWorker<Void, Void> {
/**
*
*/
public BackgroundWorker(JButton btn, JProgressBar barras) {
btns = btn;
barraProgreso = barras;
listaEntradas = MuestraEntradas.obtenEntradas();
// TODO Auto-generated constructor stub
addPropertyChangeListener(e -> {
barraProgreso.setValue(getProgress());
});
}
@Override
protected Void doInBackground() throws Exception {
// TODO Auto-generated method stub
while (!isCancelled()) {
System.out.println(isCancelled() + "---------------------------------------------------------------------------------\n" +
"--------------------------------------------------------------------------------------------------------------------------");
total = listaEntradas.size();
listaEntradas.forEach(l -> {
System.out.println("Id de entrada: " + l.getId_entrada() + " Id usuario: " + l.getId_usuario() + " IP: "
+ l.getIp_maquina() + " SO: " + l.getNombre_so() + " Kernel: " + l.getVersion_k()
+ " Tipo de usuario: " + l.getTipo() + " Jdk: " + l.getVersion_jdk()
+ " Versión base de datos: " + l.getVersion_db());
setProgress((int) (((i++) * 100) / total) + 1);
try {
Thread.sleep(200);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
System.out.printf("Error------------------->%s%n", e.getLocalizedMessage());
}
});
}
return null;
}
@Override
public void done() {
Toolkit.getDefaultToolkit().beep();
btns.setEnabled(true);
barraProgreso.setValue(0);
setProgress(0);
System.out.println("Terminado");
System.out.println("Total de registros: " + listaEntradas.size());
showMessageDialog(null, "Se han cargado todos los registros", "Monitor", INFORMATION_MESSAGE);
}
private ArrayList<ControlEntradas> listaEntradas;
private int total, i = 0;
private JButton btns;
private JProgressBar barraProgreso;
}
/**
* @author elalio
*
*/
public class UIControl extends JFrame {
public UIControl() {
// TODO Auto-generated constructor stub
super("Probando barra de progreso");
con = getContentPane();
con.setLayout(new GridLayout(4, 0));
eti = new JLabel("Empezando con JProgressBar");
barra = new JProgressBar();
barra.setStringPainted(true);
barra.setMinimum(MIN);
barra.setMaximum(MAX);
botonAcciona = new JButton("Inicia");
botonAcciona.addActionListener(e -> {
EventQueue.invokeLater(() -> {
if (!Iniciado) {
botonAcciona.setEnabled(false);
new BackgroundWorker(botonAcciona, barra).execute();
Iniciado = false;
}
});
});
botonCancela = new JButton("Cancelar");
botonCancela.addActionListener(e -> {
EventQueue.invokeLater(() -> {
new BackgroundWorker(botonAcciona, barra).cancel(true);
});
});
con.add(eti);
con.add(barra);
con.add(botonAcciona);
con.add(botonCancela);
setSize(new Dimension(ANCHURA, ALTURA));
setLocationRelativeTo(null);
setDefaultCloseOperation(JFrame.EXIT_ON_CLOSE);
repaint();
revalidate();
}
/**
*
*/
private static final long serialVersionUID = 7499538122632982906L;
private final Container con;
private final JLabel eti;
private final JButton botonAcciona, botonCancela;
private final JProgressBar barra;
private static final int MIN = 0, MAX = 100, ANCHURA = 300, ALTURA = 100;
private boolean Iniciado = false;
}