GParse call BackendService async

Question

我試圖在後端調用中實現異步，我一直在閱讀，似乎GParse是一個很好的庫來實現這一點，但它並不清楚我如何可以在一個正確的方式。誰能幫我？這是我的例子：

def itemsResults 
    def locationResults 
    def itemsNearLocation 
    GParsPool.withPool { 
     itemsResults = {searchMyItems()}.async().call() 
     locationResults = {getLocations()}.async().call() 
     itemsNearLocation = {getItemsNear(locationResults)}.async().call() // i need locationresults answer in order to call this service 

    } 
    model.putAll(["items": itemsResults, 
        "itemsNearLocation":itemsNearLocation]) 

    return "myView" 

所以，我需要調用的API 2呼叫，然後在第三個我需要使用所謂的異步前的反應之一，並最終加入到我的模型。我怎樣才能做到這一點？

Answer 1

你可以使用GPars數據流爲這個......像這樣的東西應該工作，我相信（沒有嘗試過，雖然）：

import groovyx.gpars.dataflow.Dataflows 
import static groovyx.gpars.dataflow.Dataflow.task 

final def df = new Dataflows() 

task { 
    df.itemsResults = searchMyItems() 
} 

task { 
    df.locationResults = getLocations() 
} 

task { 
    df.itemsNearLocation = getItemsNear(df.locationResults) 
} 

def lastTask = task { 
    model.putAll(["items": df.itemsResults, 
        "itemsNearLocation":df.itemsNearLocation]) 
} 

lastTask.join()