2

我需要插入有两列的数据库 -

ID      PrimaryKey String
ACCOUNT String

所以这意味着每个线程应该始终使用唯一的 id，我也需要ID在Account列中存储相同的 id。所以假设如果ID is 1然后在数据库中它应该存储为

ID  Account
1   SomeString+1
2   SomeString+2
3   SomeString+3
....
..

100 SomeString+100

我总是在帐户列中将该用户 ID 与该字符串连接起来。

下面是我的多线程代码，它将产生多个线程 - 每个线程每次都会获得一个新的唯一 ID，因为我正在使用AtomicInteger它。它会将其插入并附ID加到列ID columnIDAccount

但不知何故，在我下面的程序中，我在该数据库中看到的是 -

ID Account
1  String+2
2  String+1
3  String+3

这是不对的。应该是这样的——

ID Account
1  String+1
2  String+2
3  String+3

下面是代码

 public static void main(String[] args) {

        final int noOfThreads = 4;
        final int noOfTasks = 10;

        final AtomicInteger id = new AtomicInteger(1);

        ExecutorService service = Executors.newFixedThreadPool(noOfThreads);

        for (int i = 0; i < noOfTasks * noOfThreads; i++) {
            service.submit(new Task(id));
        }
    }


class Task implements Runnable {

    private final AtomicInteger id;
    private volatile int userId;

    public Task(AtomicInteger id) {
        this.id = id;
    }


    @Override
    public void run() {

        dbConnection = getDBConnection();

        preparedStatement = dbConnection.prepareStatement(Constants.INSERT_ORACLE_SQL);

        userId = id.getAndIncrement();

        preparedStatement.setString(1, String.valueOf(userId));
        preparedStatement.setString(2, Constants.getaAccount(userId));

        preparedStatement.executeUpdate();
    }  
}

下面是我Constants class的不可变的。

public final class Constants {

    public static String A_ACCOUNT;

    public final static String INSERT_ORACLE_SQL = "INSERT INTO XMP_TEST"
        + "("
        + "ID, A_ACCOUNT) VALUES"
        + "(?, ?)";



    public static String getaAccount(int userId) {      
        A_ACCOUNT = "{\"lv\":[{\"v\":{\"userId\":"+userId+"},\"cn\":1}]}";

        return A_ACCOUNT;
    }


}

谁能告诉我我在这里做错了什么？我相信这是因为线程安全问题而发生的。多个线程修改了userID我猜的整数，这就是为什么它被错误地写入数据库的原因。

我该如何解决这个问题？

4

3 回答 3

5

我看到的主要问题不是Task.userId，而是Constants.A_ACCOUNT：如果两个单独的线程getaAccount同时调用，那么它们都会设置Constants.A_ACCOUNT并读取它，因此它们最终可能都具有相同的值，或者每个都有另一个的值价值，或诸如此类。要解决此问题，您可以使用局部变量而不是静态字段：

    public static String getaAccount(int userId) {      
        final String ret = "{\"lv\":[{\"v\":{\"userId\":"+userId+"},\"cn\":1}]}";

        return ret;
    }

或者只是省去变量：

    public static String getaAccount(int userId) {      
        return "{\"lv\":[{\"v\":{\"userId\":"+userId+"},\"cn\":1}]}";
    }

（你说你已经做到了Constants不可变，但这不是真的。实例将Constants是不可变的，因为它们根本没有字段；但Constants它本身有一个可公开修改的字段，所以它非常可变！）

更一般地说，您不应该将字段用于仅在特定方法中需要的临时值，并且仅在对其进行一次调用期间。即使不是同步问题，也是维护问题。例如，Task不需要volatile int userId; userId应该只是其run方法中的局部变量。

另外，我建议将您包装AtomicInteger在它自己的类中，IncrementingCounter或者其他只提供一种方法的东西中，称为 (say) getNewId。然后getNewId将是唯一必须处理线程之间协调的类。所有其他类都可以通过常规技术（不变性，仅存在于单个线程中等）成为线程安全的。

于 2013-02-07T23:00:12.430 回答
1

您正在读取和修改静态变量，而无需从多个线程进行任何同步：A_ACCOUNT. 只需将其设为局部变量getaacount()，一切都应按预期工作。

于 2013-02-07T23:00:45.190 回答
1

考虑到数字的数字也是字符串，这个问题在很多年前就已经解决了：

  • 向父表添加自动增量列
  • 现在插入父记录会给你一个唯一的数字
  • 你没有说你正在使用哪个数据库，但是每个数据库都有一种方法来检索刚刚插入的自动增量的值，所以检索它并将其用作你的唯一值。

如果您的键无法更改数据类型，请将自动增量值复制到您的字符串列中。它是数字无关紧要 - 它仍然是唯一的。

于 2013-02-08T00:03:23.500 回答