google-cloud-datastore - 使用 JPA2 将数据异步放入谷歌数据存储

Question

我正在使用 JPA2@entity来表示我的模型。我需要将数据异步放入数据存储区。我该怎么做？如果 JPA Dao 无法做到这一点，我可以在 JPA 实体上使用 AsyncDatastoreService - 而不是 JPQL？有人有例子吗？

（我知道在 Python 中这将是一个笑话，因为我可以扩展ndb.Model以创建模型，然后在它们上调用 put_async。但在 Java 中没有ndb.Model扩展，所以我使用 JPA。）

Answer 1

我非常希望不必使用以下ThreadManager.createBackgroundThread. 但到目前为止，这就是我所发现的。有没有其他人有更简单的东西（比如 python 的put_async）？

import com.google.appengine.api.ThreadManager;
import java.util.concurrent.AtomicLong;

AtomicLong counter = new AtomicLong();

Thread thread = ThreadManager.createBackgroundThread(new Runnable() {
  public void run() {
    try {
      while (true) {
        counter.incrementAndGet();
        Thread.sleep(10);
      }
    } catch (InterruptedException ex) {
      throw new RuntimeException("Interrupted in loop:", ex);
    }
  }
});
thread.start();