Chạy tác vụ JavaExec ở chế độ nền và sau đó chấm dứt khi xây dựng hoàn thành

Question

Tôi đang cố gắng tìm ra cách khởi chạy tác vụ JavaExec để sinh ra một máy chủ Jetty mà không chặn các tác vụ tiếp theo. Ngoài ra, tôi sẽ cần phải chấm dứt máy chủ này sau khi xây dựng hoàn thành. Bất kỳ ý tưởng làm thế nào tôi có thể làm điều này?

Answer 1

Hy vọng đoạn mã này sẽ cung cấp cho bạn một số thông tin chi tiết về cách thực hiện.

Bạn có thể sử dụng đóng trình nghe xây dựng để chạy mã khi bắt đầu/kết thúc xây dựng. Tuy nhiên, vì một lý do nào đó, việc đóng cửa gradle.buildStarted không hoạt động trong cột mốc-3, vì vậy tôi đã thay thế nó bằng gradle.taskGraph.whenReady.

Sau đó, bạn có thể gọi nhiệm vụ runJetty bằng cách sử dụng Task#execute() (Lưu ý, API này không chính thức và có thể biến mất), và bổ sung, chạy nó từ ExecutorService để nhận một số hành vi không đồng bộ.

import java.util.concurrent.* 

task myTask << { 
    println "Do usual tasks here" 
} 

task runJetty << { 
    print "Pretend we are running Jetty ..." 
    while(!stopJetty){ 
    Thread.sleep(100) 
    } 
    println "Jetty Stopped." 
} 

stopJetty = false 
es = Executors.newSingleThreadExecutor() 
jettyFuture = null 

//gradle.buildStarted { ... } 
gradle.taskGraph.whenReady { g -> 
    jettyFuture = es.submit({ runJetty.execute() } as Callable) 
} 

gradle.buildFinished { 
    println "Stopping Jetty ... " 
    stopJetty = true 

    //This is optional. Could be useful when debugging. 
    try{ 
    jettyFuture?.get() 
    }catch(ExecutionException e){ 
    println "Error during Jetty execution: " 
    e.printStackTrace() 
    } 
} 

Answer 2

Bạn không thể làm điều đó với JavaExec; bạn sẽ phải viết nhiệm vụ của riêng bạn.

Answer 3

Tôi biết chủ đề là từ năm 2011, nhưng tôi vẫn tình cờ gặp vấn đề. Vì vậy, đây là giải pháp hoạt động với Gradle 2.14:

import java.util.concurrent.Callable 
import java.util.concurrent.ExecutorService 
import java.util.concurrent.Executors  

class RunAsyncTask extends DefaultTask { 
    String taskToExecute = '<YourTask>' 
    @TaskAction 
    def startAsync() { 
     ExecutorService es = Executors.newSingleThreadExecutor() 
     es.submit({taskToExecute.execute()} as Callable) 
    } 
} 


task runRegistry(type: RunAsyncTask, dependsOn: build){ 
    taskToExecute = '<NameOfYourTaskHere>' 
} 

Answer 4

Tôi đã cập nhật giải pháp từ @chrishuen vì bạn không thể thực hiện nhiệm vụ được nữa. Đây là hoạt động của tôi build.gradle

import java.time.LocalDateTime 
import java.util.concurrent.Callable 
import java.util.concurrent.ExecutorService 
import java.util.concurrent.Executors 

group 'sk.bsmk' 
version '1.0-SNAPSHOT' 

apply plugin: 'java' 

task wrapper(type: Wrapper) { 
    gradleVersion = '3.4' 
} 

class RunAsyncTask extends DefaultTask { 
    @TaskAction 
    def startAsync() { 
    ExecutorService es = Executors.newSingleThreadExecutor() 
    es.submit({ 
     project.javaexec { 
     classpath = project.sourceSets.main.runtimeClasspath 
     main = "Main" 
     } 
    } as Callable) 

    } 
} 

task helloAsync(type: RunAsyncTask, dependsOn: compileJava) { 
    doLast { 
    println LocalDateTime.now().toString() + 'sleeping' 
    sleep(2 * 1000) 
    } 
}