在哪里使用多线程概念

Question

我有一个要求更新数据库中可用的 300 000 条记录。当我编写一个独立程序时，它需要 25-30 分钟来更新 5 000 条记录。所以完成所有记录可能需要 30 个小时。然后我想我会写一个多线程程序。我创建了 2 个线程，然后开始更新，它花费了相同的时间意味着 5k 条记录需要 30 分钟。

据我所知，我们正在使用线程来并发访问一个方法，在这种情况下它不会加速更新。

对于上述情况，我必须做些什么来减少时间。而多线程的实际用途是什么

   class MyThread1 extends Thread{
    public static String getTaskID(String PID)
    {
        String taskID = OurGenerator.orgPID(PID);
        return taskID;
    }
    Connection con;
    PreparedStatement pstmt;
    BufferedReader bf;
    MyThread1(Connection con,PreparedStatement pstmt){
        this.con=con;
        this.pstmt=pstmt;
        try {
            bf=new BufferedReader(new FileReader("D:/prod_review_sifid3.txt"));
        }catch (IOException e) 
        {
            System.out.println("IO Error Occurred: " + e.toString());
        }
    }
    public void run(){
        String line;
        try{
          while (( line = bf.readLine()) != null)
            {
                String taskID = getTaskID(line);
                   pstmt.setString(1,taskID);
                   pstmt.setString(2,line);
                   pstmt.executeUpdate();

          }
        }catch(Exception e){
            e.printStackTrace();
        }   
    }
}
class MyThread2 extends Thread{
    public static String getTaskID(String PID)
    {
        String taskID = OurGenerator.orgPID(PID);
        return taskID;
    }
    Connection con;
    PreparedStatement pstmt;
    BufferedReader bf;
    MyThread2(Connection con,PreparedStatement pstmt){
        this.con=con;
        this.pstmt=pstmt;
        try {
            bf=new BufferedReader(new FileReader("D:/sifid_review2.txt"));
        }catch (IOException e) 
        {
            System.out.println("IO Error Occurred: " + e.toString());
        }
    }
    public void run(){
        String line;
        try{
          while (( line = bf.readLine()) != null)
            {
                String taskID = getTaskID(line);
                   pstmt.setString(1,taskID);
                   pstmt.setString(2,line);
                   pstmt.executeUpdate();

          }
        }catch(Exception e){
            e.printStackTrace();
        }   
    }
}

public class SifuuidInsert {
  public static void main(String ar[])throws Exception{
      Class.forName("oracle.jdbc.driver.OracleDriver");
      Connection con=DriverManager.getConnection("","","");
      PreparedStatement pstmt=con.prepareStatement("update Taskdata set taskID=? where entryid=?");
        MyThread1 first=new MyThread1(con,pstmt);
        first.start();
        MyThread2 second=new MyThread2(con,pstmt);
        second.start();
  }
}

Answer 1

首先：使用批量更新添加查询并在集合末尾推送，Infohere (general)和here (for oracle

第二：你只是为一个新文件重复一个类实现，只需为接收文件路径的类添加一个参数。

class MyThrea extends Thread {
    public static String getTaskID(String PID) {
        String taskID = OurGenerator.orgPID(PID);
        return taskID;
    }

    Connection con;
    BufferedReader bf;

    MyThread1(Connection con, String path) {
        this.con = con;
        this.pstmt = pstmt;
        try {
            bf = new BufferedReader(new FileReader(path));
        } catch (IOException e) {
            System.out.println("IO Error Occurred: " + e.toString());
        }
    }

    public void run() {

        PreparedStatement pstmt = con.prepareStatement("update Taskdata set taskID=? where entryid=?");
        String line;
        try {
            while ((line = bf.readLine()) != null) {
                String taskID = getTaskID(line);
                pstmt.setString(1, taskID);
                pstmt.setString(2, line);
                pstmt.addBatch();
            }

            pstmt.executeBatch();
        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}


public class SifuuidInsert {
    public static void main(String ar[]) throws Exception {
        Class.forName("oracle.jdbc.driver.OracleDriver");
        Connection con = DriverManager.getConnection("", "", "");
        MyThread first = new MyThread1(con, "path_to_file_1");
        first.start();
        MyThread second = new MyThread1(con, "path_to_file_2");
        second.start();
    }
}

可以通过先加载文件，然后执行更新来改进。

Answer 2

数据库更新的大部分工作发生在服务器上。根据特定服务器的数据库和配置，它可能有助于为服务器提供多个工作流——或者它可能会受到伤害，或者它可能根本不会改变性能。

然而，大多数情况下，除非每个线程都有自己独立的数据库连接，否则它无济于事。

Answer 3

MultiTherading 用于并发访问，而不是用于时间和性能目的。您应该通过更新一些类似的记录来尝试直接批量更新