1
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.SQLException;
import java.sql.Statement;


public class vacuum {
    public static void connect(String str) {
        Connection conn = null;
        Statement stmt = null;
        try {
            String url = "jdbc:sqlite:/data/" + str;
            conn = DriverManager.getConnection(url);
            stmt = conn.createStatement();
            stmt.executeUpdate("VACUUM");

            System.out.println(str + "ok.");

        } catch (SQLException e) {
            System.out.println(e.getMessage());
        } finally {
            try {
                if (conn != null) {
                    conn.close();
                }
            } catch (SQLException ex) {
                System.out.println(ex.getMessage());
            }
        }
    }

    public static void main(String[] args) {
        String str = "db1.lgd";
        connect(str);
    }
}

Есть несколько Sqlite баз, которым нужно делать вакум. Хочу делать вакум всем база в нескольких паралелльных потоках. Т.е. в метод connect передавать список баз из массива и сам метод запускать в отдельном потоке. Выше, рабочий код, который делать вакум для одной базы. Подскажите, это реализовать?

2
  • Выполняйте код метода connect в отдельном потоке, а с главного стартуйте эти потоки с нужными вам параметрами. В чём конкретно сложности? 25 окт 2017 в 8:06
  • Не работал с потоками. Можете показать пример ?
    – Slaine
    25 окт 2017 в 8:09

3 ответа 3

2

Нужно создать объект Thread, передать в него Runnable и запустить методом start, на Java 8 будет выглядеть так

public static void main(String[] args) {
    new Thread(()->connect("db1.lgd")).start();
    new Thread(()->connect("db2.lgd")).start();
}
1

Согласно концепции параллельных потоков время выполнение каждого вызова метода connect() в большинстве случаев не суммируется. Порядок выполнения каждого из потоков определяется CPU и чисто теоретически, конечно, возможна ситуация, что второй поток начал выполняться ровно после того, как завершился первый. На практике же такая ситуация маловероятна, и в Вашем случае время выполнения чаще всего будет около 7 минут.

В дополнении к этому, советую в данном примере использовать не обычный Statement, а лучше PreparedStatement или CallableStatement, так как оба sql-запроса имеют одинаковый синтаксис и будут прекомпилированы, что увеличит производительность.

0

Спасибо. Сделал так:

public class vacuum extends Thread {
public static void connect(String str) {
    Connection conn = null;
    Statement stmt = null;
    try {
        String url = "jdbc:sqlite:/data/" + str;
        conn = DriverManager.getConnection(url);
        stmt = conn.createStatement();
        stmt.executeUpdate("VACUUM");

        System.out.println(str + " ok.");

    } catch (SQLException e) {
        System.out.println(e.getMessage());
    } finally {
        try {
            if (conn != null) {
                conn.close();
            }
        } catch (SQLException ex) {
            System.out.println(ex.getMessage());
        }
    }
}

public static void main(String[] args) {
    new Thread(()->connect("db1.lgd")).start();
    new Thread(()->connect("db2.lgd")).start();
}
}

Так время вакумизации занимает такое же время, если бы делать вакум каждой базы последовательно. Т.е. db1.lgd - 7 мин., db2.lgd - 2 минуты. Если в многопоточном режиме то теже 9 минут получаются.

Ваш ответ

By clicking “Отправить ответ”, you agree to our terms of service and acknowledge you have read our privacy policy.

Всё ещё ищете ответ? Посмотрите другие вопросы с метками или задайте свой вопрос.