Arraylist заполнен параллельным потоком содержит нулевые значения и оставляет некоторые из них ⇐ JAVA

[Anonymous]

Я пытаюсь заполнить ArrayList, так как обычно есть очень большие значения, которые я решил параллелизировать его с ExecutorService и завершением, а затем с параллельным потоком, но в обоих случаях результаты всегда меньше исходного размера Первоначального списка, и всегда есть одно из этих значений, которое остается нулевым.

Код: Выделить всё

//results It's filled with a query from the database

results.parallelStream().forEach((in) -> {
Float reintegroConv = 0f;
Float retribucion = 0f;
ConvenioDto conv = new ConvenioDto();
/*Carga de campos que tienen texto_id*/
String tipoPrescNombre = "";
String promoNombre = "";
String tipoPlantNombre = "";
String modeloPlantNombre = "";
String estadoPlantNombre = "";
String convenioNombre = "";
String tipoConvenioNombre = "";
String servicioNombre = "";
String nombreColaborador = "";
//String tipoRetoqueNombre = "";
//String primerEstadoPlantNombre = "";
if (in.getTipoPrescriptorNombre() != null) {
tipoPrescNombre = textosMap.get(Integer.parseInt(in.getTipoPrescriptorNombre()));
}
if (in.getPromocionNombre() != null) {
promoNombre = textosMap.get(Integer.parseInt(in.getPromocionNombre()));
}
if (in.getTipoPlantillaNombre() != null) {
tipoPlantNombre = textosMap.get(Integer.parseInt(in.getTipoPlantillaNombre()));
}
if (in.getModeloPlantillaNombre() != null) {
modeloPlantNombre = textosMap.get(Integer.parseInt(in.getModeloPlantillaNombre()));
}
if (in.getServicioNombre() != null) {
servicioNombre = textosMap.get(Integer.parseInt(in.getServicioNombre()));
}
if (in.getEstadoPlantillaId() != null) {
estadoPlantNombre = EstadoPlantillaDto.getFromId(in.getEstadoPlantillaId()).getNombre();
}

/*if (in.getPrimerEstadoPlantillaId() != null) {
primerEstadoPlantNombre = EstadoPlantillaDto.getFromId(0).getNombre();
}
if (in.getTipoRetoqueId() != null) {

tipoRetoqueNombre = tiposRetoqueMap.get(Integer.parseInt(in.getTipoRetoqueId()));
}*/
if (in.getImporteTotServ() == null) {
in.setImporteTotServ(0f);
}
if (in.getConvenioId() != null) {

conv.setTipo(in.getConvenioTipoId());
convenioNombre = in.getConvenioNombre();
tipoConvenioNombre = conv.getTipoNombre();
}
if (in.getPodologoColaborador() != null && in.getPodologoColaborador() != "") {
nombreColaborador = in.getPodologoColaborador();
}
if (in.getIva() != null && in.getIva() != 0) {
in.setImporteTotServ(in.getBaseImponible() + (in.getBaseImponible() * in.getIva() / 100));
} else {
in.setImporteTotServ(in.getBaseImponible());
}
/*Busqueda Podo colaborador y servicio si existen*/
// int idColaborador = 9999;
// if (in.getServicioId() == null) {
//    idColaborador = podologoDAO.getIdColaborador(in.getCitaPagoCitaId(), 9999);
// } else {
//   idColaborador = podologoDAO.getIdColaborador(in.getCitaPagoCitaId(), in.getServicioId());

if (in.getConvenioId() != null && in.getServicioId() != null) {
ConvenioServicio convServ = convServMap.get(in.getConvenioId() + "_" + in.getServicioId());

if (in.getEdadPac() != null && in.getConvenioId() != null && conv.isPartCon() && convServ != null) {
if (in.getEdadPac() >  Constants.PACIENTE_MENOR_EDAD) {
reintegroConv = convServ.getPrecio_adulto_seguro();
} else {
reintegroConv = convServ.getPrecio_infantil_seguro();
}
}
}
if (in.getConsultaGenericaServicioNombre() != null && !in.getConsultaGenericaServicioNombre().equals("")) {
reintegroConv = in.getPrecioSeguro() != null && in.getPrecioSeguro() > -1 ? in.getPrecioSeguro() : null;
}
float rConv = reintegroConv != null ? reintegroConv : 0;
ClienteJcoPodologo comisionPod = null;

if (in.getPodologoId() != null) {

comisionPod = cliJroPodMap.get(in.getPodologoId() + "_" + in.getCliJurId());

}

if (comisionPod != null && in.getServicioId() != null && in.getProductoNombre() == null) {
float comision = 0;
switch (in.getServicioTipoId()) {
case Constants.TIPO_SERVICIO_PRINCIPAL:
comision = comisionPod.getComisionBiomecanica();
break;
case Constants.TIPO_SERVICIO_QUIROPODIA:
case Constants.TIPO_SERVICIO_QUIROPODIA_CITA:
comision = comisionPod.getComisionQuiropodia();
break;
case Constants.TIPO_SERVICIO_YOUNEXT_BIKE:
comision = comisionPod.getComisionYounext();
}
retribucion = Precio.redondear((in.getBaseImponible() + rConv) * (comision / 100));
}
// }

String horaString = "";
try {
SimpleDateFormat formatter = new SimpleDateFormat("HH:mm");
horaString = formatter.format(in.getFecha());

} catch (Exception e) {
System.out.println(e.getMessage());
}

ret.add(new InformeFacturacionAsociadoDto(
in.getFecha(),
horaString,
in.getCodigoFactura(),
in.getCliJurNombre(),
in.getCentroNombre(),
in.getPodologoNombreFormal(),
servicioNombre,
in.getTipoRetoqueId(),
in.getGarantia(),
in.getEnCentro(),
in.getProductoNombre(),
in.getCodigoPlantilla(),
tipoPlantNombre,
modeloPlantNombre,
estadoPlantNombre,
in.getBaseImponible(),
in.getIva(),
in.getImporteTotServ(),
reintegroConv,
retribucion,
in.getApellido1Pac() + " " + in.getApellido2Pac() + " ," + in.getNombrePac(),
in.getProvinciaTxtPac(),
in.getEdadPac(),
tipoConvenioNombre,
convenioNombre,
promoNombre,
tipoPrescNombre,
in.getPrescriptorNombre(),
formasPagoMap.get(in.getFormaPagoId()),
0/*paciente_id no sirve para este informe*/,
nombreColaborador));

});

Я пытался параллелизировать его двумя способами, которые я упоминаю, но результат одинаково.

Подробнее здесь: https://stackoverflow.com/questions/794 ... s-some-out