Cassandra BoundStatement 的线程安全

Question

本文档指导如何使用Cassandra准备语句和绑定语句。

上面写着：

您应该只准备一次，并在应用程序中缓存准备好的声明（它是线程安全的）。...绑定状态不是线程安全的。您可以使用不同的参数多次重用一个实例，但只能从单个线程重用，并且只有在使用同步调用时：

BoundStatement bound = ps1.bind();

// This is safe:
bound.setString("sku", "324378");
session.execute(bound);

bound.setString("sku", "324379");
session.execute(bound);

// This is NOT SAFE. executeAsync runs concurrently with your code, so the first execution might actually read the
// values after the second setString call, and you would insert 324381 twice:
bound.setString("sku", "324380");
session.executeAsync(bound);

bound.setString("sku", "324381");
session.executeAsync(bound);

很明显，上面的代码不是线程安全的，但如果我们这样更改代码：

BoundStatement bound1 = ps1.bind();
BoundStatement bound2 = ps1.bind();

bound1.setString("sku", "324380");
session.executeAsync(bound1);

bound2.setString("sku", "324381");
session.executeAsync(bound2);

那就是：对多个线程使用通用的准备语句，每个线程都使用自己的边界语句。

1）这个线安全吗？

2)对于预处理语句的并行执行，这是推荐的方式吗？或者说，BoundStatements创建/消耗大量内存的成本高/速度慢，等等，是保持其数量较少的原因吗？

Answer 1

简短的回答是，如果您正在考虑多次使用同一PreparedStatement对象，但每次使用不同的BoundStatement对象绑定时使用不同的参数，那么它是线程安全的，因为 是线程安全，因此您可以在多个线程中重新使用它，而 不是线程安全的每次都有不同的对象。

为了清楚起见 - 因此，您的线程 1 将使用 ps1 = session.prepare（“插入到产品（sku、描述）值 （?, ?）”） 中创建您的 prepare 语句，所有其他线程都将使用此 ps1 对象来创建自己的 BoundStatement 对象，因为每个线程都有自己的要传递的值，例如：

线程 1 将绑定并执行为（请注意，使用相同的 ps1 对象）：

BoundStatement bound = ps1.bind().setString("sku", "001").setString("description", "LCD screen"); 
session.execute(bound);

线程 2 将绑定并执行为（请注意，使用相同的 ps1 对象）：

BoundStatement bound = ps1.bind().setString("sku", "002").setString("description", "TFT screen"); 
session.execute(bound);

线程3将绑定并执行为（请注意，使用相同的＜code＞ps1＜/code＞对象）：

BoundStatement bound = ps1.bind().setString("sku", "003").setString("description", "LED screen"); 
session.execute(bound);

简而言之：创建＜code＞PreparedStatement＜/code＞对象时会产生很大的性能成本，因为它需要往返于DB服务器（见下图），因此您可以重用它，并且它是线程安全的，而您每次创建一个单独的＜code＜BoundStatement＜/code＞对象，因为它不是线程安全的并且它不是一个很重的创建对象，并且不需要往返于数据库服务器。