API очередей задач Google AppEngine

<queue-entries>
<!--Set the number of max concurrent requests to 10-->  
<queue>    
     <name>optimize-queue</name>                 <rate>20/s</rate>  
     <bucket-size>40</bucket-size>      
   <max-concurrent-requests>10</max-concurrent-requests>     </queue> </queue-entries> 

 Пример кода
Это очень простой пример. Как я уже говорил, очереди задач в основном являются обработчиками URL. В этом сервлете GET будет обрабатывать поставленную задачу. Задача отправит POST к этому же сервлету и выполнит метод doPost (), выполняющий задачу. В данном случае это просто простой счетчик. Обратите внимание, что счетчик является изменчивым свойством. Если вы получите доступ к этому сервлету как запрос GET, он поставит в очередь другую задачу. Таким образом, вы увидите, что счетчик увеличивается с помощью обеих задач.

public class TaskQInfo extends HttpServlet {

   private static volatile int TASK_COUNTER = 0;


   // Executed by user menu click
   public void doGet(HttpServletRequest req, HttpServletResponse resp)
        throws IOException {

       // Build a task using the TaskOptions Builder pattern from ** above
       Queue queue = QueueFactory.getDefaultQueue();
       queue.add(withUrl("/taskq_demo").method(TaskOptions.Method.POST)); 

       resp.getWriter().println( 
             "Task have been added to default queue...
");
       
       resp.getWriter().println(
             "Refresh this page to add another count task");
}

   // Executed by TaskQueue
   @Override
    protected void doPost(HttpServletRequest req, HttpServletResponse resp)
       throws ServletException, IOException {
       
       // This is the body of the task
       for(int i = 0; i < 1000; i++) {
             log.info("Processing: " + req.getHeader("X-AppEngine-TaskName") + "-" +           
               TASK_COUNTER++); 
              try { 
                 // Sleep for a second (if the rate is set to 1/s this will allow at 
                           most 1 more task to be processed)
                 Thread.sleep(1000); 
              } catch (InterruptedException e) { // ignore}
       }
    }
}

Очереди задач позволяют вам достичь некоторого уровня параллелизма в вашем приложении, вызывая фоновые процессы по требованию. Для очень длительных задач вы можете взглянуть на бэкэнды App Engine , которые в основном являются специальными экземплярами App Engine без ограничения времени запроса.