Grails блок тест + Thread

Question

I, имеющие функцию Grails, где я использую отдельную тему:

def testFunction() { 
    //..... 
    Thread.start() { 
    testService.somefunction() 
    } 
    //... 

} 

В тестовом модуле, я насмешливый сервисную функцию, как это:

def "test testfunction" { 
    //... 
    1 * testService.somefunction(_) 
    //.. 
} 

Однако я получаю ошибку непревзойденных вызовов, потому что Spock не обнаружил, что метод был выполнен в отдельном потоке.

1 * testService.somefunction(_) (0 invocations) 
Unmatched invocations (ordered by similarity): 

Я попытался с помощью этого http://spock-framework.readthedocs.org/en/latest/new_and_noteworthy.html#polling-conditions, но не имели никакого успеха.

Обновленный включает пример кода:

void "test without errors"() { 

     def conditions = new PollingConditions(timeout: 15) 

     def cmdList = new ArrayList<CommandClass>() 
     parseService.parseFile(file, _) >> commandList 
     nextService.create(_) >> commandList 
     controller.controllerService = nextService 
     controller.controllerParseService = parseService 

     when: 
     controller.testFunction() 

     then: 
     conditions.eventually { 
      assert response.contentAsString == "SUCCESS" 
     } 
    } 

Answer 1

Per исходного код, вы, к сожалению, не можете проверить количество вызовов в традиционном способе, потому что в закрытии вы должны утверждает условие, так как закрытие не находится в контексте исполнителя спока. Я бы рекомендовал что-то вроде этого, который работал для меня:

def "test concurrency"(){ 
     given: 
      def conditions = new PollingConditions(timeout: 15) 
      MyService service = new MyService() 
      SomeService someService = Mock() 
      service.validationService = someService 
      int numInvocations = 0 
      someService.methodExecutedInThread(_) >> { 
       numInvocations++ 
       return null 
      } 
     when: 
      int i = 0 
      service.aMethod() 
     then: 
      conditions.eventually { 
       println "checked ${i}" // <--- you should see this checking repeatedly until the condition is met 
       i++ 
       assert numInvocations == 1 
      } 
    } 

Учитывая метод в «сервис»:

public void aMethod(){ 
     Thread.start{ 
      sleep(5000) 
      println "awake!" 
      someService.methodExecutedInThread("some param") 
     } 
    } 

Основываясь на своем обновленном примере кода:

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