Как реализовать эту программу чтения / записи текстового файла с использованием потоков в Java?

Question

У меня есть текстовый файл, который содержит 1300000 строк. Я написал код Java для импорта его в базу данных MySQL. В классе Java у меня есть метод с именем textloadutility (), который вызывается со страницы jsp. Может кто-нибудь датьреализация асинхронного потока этой Java-программы.

package Snomed;
import catalog.Root;
import java.io.*;
import java.sql.PreparedStatement;
import org.json.JSONObject;

public class Textfileimport {


    public String textloadutility() throws Exception {

        Root oRoot = null;

        PreparedStatement oPrStmt = null;

        FileReader in = null;

        BufferedReader br=null;

        final int batchSize = 1000;

        int count = 0;

        JSONObject oJson = null;



        String str=null;

        oJson = new JSONObject();

         oJson.put("status","failure");

         str=oJson.toString();


        try {


             oRoot = Root.createDbConnection(null);




             String sql = "INSERT INTO textfiledata (col1,col2,col3,col4,col5,col6,col7,col8,col9) VALUES( ?, ?, ?,?,?,?,?,?,?)";

             oPrStmt = oRoot.con.prepareStatement(sql);

            in = new FileReader("C:/Users/i2cdev001/Desktop/snomedinfo_data.txt");      

            br = new BufferedReader(in);

            String strLine;

            while ((strLine = br.readLine()) != null){

                String [] splitSt =strLine.split("\\t");
                String dat1="",dat2="",dat3="",dat4="",dat5="",dat6="",dat7="",dat8="",dat9="";
                dat1=splitSt[0];
                dat2=splitSt[1];
                dat3=splitSt[2];
                dat4=splitSt[3];
                dat5=splitSt[4];
                dat6=splitSt[5];
                dat7=splitSt[6];
                dat8=splitSt[7];
                dat9=splitSt[8];        




                oPrStmt.setString(1, dat1);
                oPrStmt.setString(2, dat2);
                oPrStmt.setString(3, dat3);
                oPrStmt.setString(4, dat4);  
                oPrStmt.setString(5, dat5);
                oPrStmt.setString(6, dat6);
                oPrStmt.setString(7, dat7);
                oPrStmt.setString(8, dat8);
                oPrStmt.setString(9, dat9);
                oPrStmt.addBatch();

                if (++count % batchSize == 0) {
                    oPrStmt.executeBatch();
                    oPrStmt.clearBatch(); 
                   }                
            }

            oPrStmt.executeBatch();

             oJson.put("status","sucess");

             str=oJson.toString(); 

             in.close();
                br.close();



            System.out.println("sucessfully imported");

        }
        catch (Exception e) {


            oJson.put("status","failure");

             str=oJson.toString(); 
            e.printStackTrace();
            System.err.println("Error: " + e.getMessage());

        } finally {
            oPrStmt = Root.EcwClosePreparedStatement(oPrStmt);

            oRoot = Root.closeDbConnection(null, oRoot);
        }
        return str;
    }

}

Answer 1

Вот решение вашей проблемы,

1. Файловый ввод-вывод не должен быть асинхронным, поэтому сначала Thread-1 должен прочитать файл пакета за пакетом и поместить его в некоторую общую очередь.
2. Другой многопоточный поток должен прочитать содержимое очереди и вставить его в базу данных.Вы можете реализовать это, используя класс ExecutorService java-параллельного пакета.И координируйте все эти потоки, используя защелку CountDown.
3. Как только все строки будут считаны из файла одним потоком, он вернется к вызывающей стороне.
4. После того, как все эти записи в очереди будутобработанные потоки обработки БД будут закрыты, и соответствующая защелка обратного отсчета также будет уменьшена и завершится после того, как она переместится на 0.
5. Вы должны использовать будущий ответ фактическому вызывающему, чтобы после завершения всех этих потоков вы былиполучить ответ.

Это высокоуровневое представление.