5

我正在尝试TimerTask设置以定期从 Google App Engine 的数据存储中删除条目。所以我ServletContextListener用Timer.

在里面contextInitialized，我已经注册了我的 Objectify 类：

ObjectifyService.register(Person.class);

但是，当任务实际运行时，它会抱怨没有设置 API 环境：

Exception in thread "Timer-0" java.lang.NullPointerException: No API environment is registered for this thread.
    at com.google.appengine.api.datastore.DatastoreApiHelper.getCurrentAppId(DatastoreApiHelper.java:80)
    at com.google.appengine.api.datastore.DatastoreApiHelper.getCurrentAppIdNamespace(DatastoreApiHelper.java:90)
    at com.google.appengine.api.datastore.Query.<init>(Query.java:214)
    at com.google.appengine.api.datastore.Query.<init>(Query.java:143)
    at com.googlecode.objectify.impl.cmd.QueryImpl.<init>(QueryImpl.java:72)
    at com.googlecode.objectify.impl.cmd.LoadTypeImpl.createQuery(LoadTypeImpl.java:50)
    at com.googlecode.objectify.impl.cmd.LoadTypeImpl.filter(LoadTypeImpl.java:58)
    at myApp.MyServletContextListener$MyTask.run(MyServletContextListener.java:58)
    at java.util.TimerThread.mainLoop(Timer.java:555)
    at java.util.TimerThread.run(Timer.java:505)

有任何想法吗？我尝试将注册类的行更改为，ObjectifyService.factory().register(Person.class);但似乎没有帮助。

4

1 回答 1

6

从类的文档java.util.Timer：

每个 Timer 对象对应的是单个后台线程。

并且查看类的内部代码java.util.Timer，我们可以看到它基本上是通过调用来实例化线程new Thread()。

同时，来自App Engine 的关于在其 Java 沙箱中使用线程的文档：

您必须使用ThreadManager上的一种方法来创建线程。您不能自己调用​​ new Thread()或使用默认线程工厂。

所以这里发生的事情是Timer对象实例化了它们自己的线程，然后执行 Objectify 查询，但是由于在 ThreadManager 之外实例化的线程没有为它们设置适当的 App Engine API 环境，它会引发异常。

您需要重构代码以避免使用 Timer 和 TimerTask 类，而使用基本线程。例如，而不是使用：

import java.util.Timer;
import java.util.TimerTask;

...

Timer timer = new Timer();
timer.schedule( new TimerTask()
{
    @Override
    public void run()
    {
        // Objectify query here.
    }
}, 5000 );

您可以改为使用：

import com.google.appengine.api.ThreadManager;

...

final long tScheduleDelay = 5000;
ThreadManager.createThreadForCurrentRequest( new Runnable()
{
    @Override
    public void run()
    {
        try
        {
            Thread.sleep( tScheduleDelay );
        }
        catch ( InterruptedException ex )
        {
            // log possible exception
        }

        // Objectify query here.
    }
} ).start();
于 2013-04-12T19:22:40.633 回答