java - JNI : Does C++ calls Java asynchronous?

Question

我正在尝试使用 JNI 从 C++ 代码调用一些 java 类。今天我在程序中经历了一个非常奇怪的行为。我怀疑c++代码没有等到java端完成它的工作，我不知道为什么。

C++ 代码(在共享对象库中)在它自己的 C++ 线程中运行。它使用已启动并运行的 Java 应用程序的现有 JavaVM。当 java 应用程序在 JNI_Onload 中加载共享对象库时，会获取对 VM 和 ClassLoader 的引用。这里我在C++线程中调用我用JNI创建的java对象的java方法:

env->CallVoidMethod(javaClassObject, javaReceiveMethod, intParam, byteParam, objectParam);
uint32_t applicationSideResponseCode = getResponseCode(objectClass, objectParam, env);
resp.setResponseCode(applicationSideResponseCode);
std::string applicationData = getApplicationData(serviceResultClass, serviceResultObject, env);
resp.setData(applicationData);

Java javaReceiveMethod 正在访问数据库并获取一些存储在 objectParam 中的 applicationData。不幸的是，C++ 代码在 java 类完成其工作之前就获取了 applicationData。 applicationData 为 null 并且 JNI 崩溃。为什么？我找不到任何 Oracle 文档说明 CallVoidMethod 是异步执行的？

编辑

我验证了java方法没有发生异常。一切看起来都很好，除了 Java 仍然很忙，而 C++ 正在尝试访问数据。

编辑

我可以确认，如果我调试 java 应用程序，则会显示两个线程。在主线程上，正在执行 javaReceiveMethod 和一个正在获取 applicationData 的线程。我怎么解决这个问题？在数据可用之前第二个线程处于空闲状态？

编辑

在我的 C++ 代码中，我正在创建一个我想要调用的 java 类的新对象:

jmethodID javaClassConstructor= env->GetMethodID(javaClass, "<init>", "()V");
                    jobject serviceObject = env->NewObject(javaClass, serviceConstructor);
jobject javaClassObject = env->NewObject(javaClass, javaClassConstructor);

之后我调用如上所示的代码。经过更多调试后，我可以说该方法是在名为 Thread-2 的线程中调用的(我不知道这是 C++ 线程还是来自 JNI 的新线程)。肯定不是java主线程。然而该方法的工作被中断。这意味着如果我调试代码，我可以看到数据很快就会设置，但在下一个调试步骤中，将执行 getApplicationData 方法(只有在 c++ 调用它时才会发生)。

编辑 我调用的Java方法:

public int receive(int methodId, byte[] data, ServiceResult result){
        log.info("java enter methodID = " + methodId + ", data= " + data);  

        long responseCode = SEC_ERR_CODE_SUCCESS;

        JavaMessageProto msg;
        try {
            msg = JavaMessageProto (data);
            log.info("principal: " + msg.getPrincipal());       
            JavaMessage message = new JavaMessage (msg);

            if(methodId == GET_LISTS){
                //this is shown in console
                System.out.println("get lists");                
                responseCode = getLists(message);
                //this point is not reached 
                log.info("leave");  
            }           
            //[... different method calls here...]
            if(responseCode != SEC_ERR_CODE_METHOD_NOT_IMPLEMENTED){
                //ToDoListMessageProto response = message.getProtoBuf();
                JavaMessageProto response = JavaMessageProto.newBuilder()   
                        .setToken(message.getToken())
                        .setPrincipal(message.getPrincipal()).build();
                byte[] res = response.toByteArray();                
                result.setApplicationData(response.toByteArray());
            }
            else{
                result.setApplicationData("");
            }

        } catch (InvalidProtocolBufferException e) {
            responseCode = SEC_ERR_CODE_DATA_CORRUPTED;
            log.severe("Error: Could not parse Client message." + e.getMessage());
        }               

        result.setResponseCode((int)responseCode);
        return 0;
    }

第二种方法是

public long getLists(JavaMessage message) {
log.info("getLists enter");

String principal = message.getPrincipal();
String token = message.getToken();  

if(principal == null || principal.isEmpty()){           
    return SEC_ERR_CODE_PRINCIPAL_EMPTY;
}       
if(token == null || token.isEmpty()){       
    return SEC_ERR_CODE_NO_AUTHENTICATION;
}       

//get user object for authorization
SubjectManager manager = new SubjectManager();
Subject user = manager.getSubject();

user.setPrincipal(principal);
long result = user.isAuthenticated(token);
if(result != SEC_ERR_CODE_SUCCESS){
    return result;
}   
try {
    //fetch all user list names and ids         
    ToDoListDAO db = new ToDoListDAO();     
    Connection conn = db.getConnection();       
    log.info( principal + " is authenticated");
    result = db.getLists(conn, message);
    //this is printed
    log.info( principal + " is authenticated");         
    conn.close();   //no exception here
    message.addId("testentry");
    //this not          
    log.info("Fetched lists finished for " + principal);
} catch (SQLException e) {  
    log.severe("SQLException:" + e.getMessage());
    result = SEC_ERR_CODE_DATABASE_ERROR;
}           

return result;
}

Answer 1

CallVoidMethod 同步执行。

也许你在c++端有异常？，你使用c++ jni异常检查吗？:

env->CallVoidMethod(javaClassObject, javaReceiveMethod, intParam, byteParam, objectParam);
if(env->ExceptionOccurred()) {
   // Print exception caused by CallVoidMethod
   env->ExceptionDescribe();
   env->ExceptionClear();
}

The C++ code (in a shared object library) is running in it's own C++ thread. It is using a existing JavaVM of a java app that is already up and running.

不清楚您是否已将当前线程附加到虚拟机。确保 env 来自 AttachCurrentThread 调用。您可以在这里找到示例:How to obtain JNI interface pointer (JNIEnv *) for asynchronous calls .