java - 处理多线程以从结果集中创建受密码保护的 Excel

Question

我们需要访问 Excel 导出方法，该方法将连接到数据库并将结果集写入 Excel。

多个线程将同时访问此方法来创建受密码保护的 Excel 文件。但是当多个线程尝试访问此方法时，我们会遇到 java.lang.InterruptedException 的问题。

您能帮忙解决这个问题吗？下面是exportExcel方法代码。

public void exportTOExcel(ExportReport exportReport) {
        Connection connection = null;
        ResultSet rs = null;
        Statement statement = null;
        try {
            String fileName = exportReport.getReportName() + "_"
                    + new SimpleDateFormat("MMM_dd_yyyy_hh_mm_ss_SSS").format(Calendar.getInstance().getTime());

            String sheetName = exportReport.getReportName();
            connection = DatabaseConnection.openDBConnection();
            statement = connection.createStatement();
            rs = statement.executeQuery(exportReport.getQuery());
            SXSSFWorkbook wb = new SXSSFWorkbook(100);
            Sheet workSheet = wb.createSheet(sheetName);
            DataFormat fmt = wb.createDataFormat();
            CellStyle cellStyle = wb.createCellStyle();
            cellStyle.setDataFormat(fmt.getFormat("@"));

            int rowNumber = 1;
            String excelFile = PropertyLoader.FILE_DOWNLOAD_PATH + "\\" + fileName + ".xlsx";
            while (rs.next()) {
                Row row = workSheet.createRow(rowNumber);
                for (int i = 1; i <= rs.getMetaData().getColumnCount(); i++) {
                    String value = String.valueOf(rs.getObject(i));
                    if (value == null) {
                        value = "";
                    }
                    Cell cell = row.createCell(i - 1);
                    cell.setCellStyle(this.stringCellStyle);
                    cell.setCellValue(value);
                }

                rowNumber++;
            }

            for (int i = 1; i <= rs.getMetaData().getColumnCount(); i++) {
                workSheet.autoSizeColumn((short) i);
            }

            FileOutputStream out = new FileOutputStream(excelFile);
            wb.write(out);
            out.close();

            POIFSFileSystem fs = new POIFSFileSystem();
            EncryptionInfo info = new EncryptionInfo(fs, EncryptionMode.agile);

            Encryptor enc = info.getEncryptor();
            enc.confirmPassword(exportReport.getPassword());

            OPCPackage opc = OPCPackage.open(excelFile, PackageAccess.READ_WRITE);
            OutputStream os = enc.getDataStream(fs);
            opc.save(os);
            opc.close();
            FileOutputStream fos = new FileOutputStream(excelFile);
            fs.writeFilesystem(fos);
            fos.close();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }

Answer 1

想象一个场景。自助餐厅里有很多人想喝咖啡。但问题是只有一个杯子。假设有 4 个人在不同的时间来喝咖啡。第一个人过来接过杯子，装满咖啡并开始喝。然后，第二个人过来抢走了他的杯子，扔掉了他的咖啡。他又倒满咖啡，开始喝。如此下去。您可以实现连接池，以便在新线程到来时创建和重用连接。定义一些调度机制。