Chinaunix

标题: JavaNative 使用C多线程库的问题 [打印本页]
作者: 方兆国    时间: 2013-07-19 11:37
标题: JavaNative 使用C多线程库的问题
Java类文件
  1. package com.fangzhaoguo.primefinder;

  3. public class NativeConcurrentPrimeFinder {

  5.         static {
  6.                 System.loadLibrary("libJavaNative_ConcurrentPrimeFinder");
  7.         }

  9.         public NativeConcurrentPrimeFinder() {
  10.         }

  12.         public native boolean isPrime(final long number);

  14.         public native int countPrime(final long number);

  16.         public native int countPrime(final long lower, final long upper);
  17. }
复制代码
javah后的C头文件，并且经过我的修改，加入了自定义的变量、数据结构以及函数
  1. /* DO NOT EDIT THIS FILE - it is machine generated */
  2. #include "jni.h"
  3. #include <pthread.h>
  4. #include <stdio.h>
  5. #include <malloc.h>
  6. #include <math.h>
  7. /* Header for class com_fangzhaoguo_primefinder_NativeConcurrentPrimeFinder */
  8. jint total = 0;

  10. typedef struct {
  11.         JNIEnv *env;
  12.         jobject obj;
  13.         jlong lower;
  14.         jlong upper;
  15. } Message;

  17. #ifndef _Included_com_fangzhaoguo_primefinder_NativeConcurrentPrimeFinder
  18. #define _Included_com_fangzhaoguo_primefinder_NativeConcurrentPrimeFinder
  19. #ifdef __cplusplus
  20. extern "C" {
  21. #endif
  22.         /*
  23.          * Class:     com_fangzhaoguo_primefinder_NativeConcurrentPrimeFinder
  24.          * Method:    isPrime
  25.          * Signature: (J)Z
  26.          */
  27.         JNIEXPORT jboolean JNICALL Java_com_fangzhaoguo_primefinder_NativeConcurrentPrimeFinder_isPrime(
  28.                         JNIEnv *, jobject, jlong);

  30.         /*
  31.          * Class:     com_fangzhaoguo_primefinder_NativeConcurrentPrimeFinder
  32.          * Method:    countPrime
  33.          * Signature: (J)I
  34.          */
  35.         JNIEXPORT jint JNICALL Java_com_fangzhaoguo_primefinder_NativeConcurrentPrimeFinder_countPrime__J(
  36.                         JNIEnv *, jobject, jlong);

  38.         /*
  39.          * Class:     com_fangzhaoguo_primefinder_NativeConcurrentPrimeFinder
  40.          * Method:    countPrime
  41.          * Signature: (JJ)I
  42.          */
  43.         JNIEXPORT jint JNICALL Java_com_fangzhaoguo_primefinder_NativeConcurrentPrimeFinder_countPrime__JJ(
  44.                         JNIEnv *, jobject, jlong, jlong);

  46.         void *countPrimeInRange(void* mess);

  48. #ifdef __cplusplus
  49. }
  50. #endif
  51. #endif
复制代码
Mingw编译的C文件 ，使用了pthread头文件，并且在链接时使用了pthread，编译正常
线程调用时通过message来传递JavaNative特有的参数
  1. /*
  2. * com_fangzhaoguo_primefinder_NativeConcurrentPrimeFinder.c
  3. *
  4. *  Created on: 2013年7月18日
  5. *      Author: root
  6. */

  8. #include "com_fangzhaoguo_primefinder_NativeConcurrentPrimeFinder.h"

  10. JNIEXPORT jboolean JNICALL Java_com_fangzhaoguo_primefinder_NativePrimeFinder_isPrime(
  11.                 JNIEnv *env, jobject obj, jlong number) {
  12.         jlong i = 0;
  13.         if (1 >= number) {
  14.                 return 0;
  15.         }
  16.         for (i = 2; i <= sqrt(number); i++) {
  17.                 if (0 == number % i) {
  18.                         return 0;
  19.                 }
  20.         }
  21.         return 1;
  22. }

  24. void *countPrimeInRange(void* mess) {
  25.         jlong i = 0;
  26.         Message* message = (Message*) mess;
  27.         for (i = message->lower; i < message->upper; i++) {
  28.                 if (Java_com_fangzhaoguo_primefinder_NativePrimeFinder_isPrime(
  29.                                 message->env, message->obj, i)) {
  30.                         total++;
  31.                 }
  32.         }
  33.         return NULL;
  34. }

  36. JNIEXPORT jint JNICALL Java_com_fangzhaoguo_primefinder_NativePrimeFinder_countPrime__J(
  37.                 JNIEnv *env, jobject obj, jlong number) {
  38.         pthread_t thread[4];
  39.         Message* message = (Message*) malloc(sizeof(Message));
  40.         message->env = env;
  41.         message->obj = obj;
  42.         jlong start = 0, end = 0;
  43.         jlong range = number / 4;
  44.         jint i = 0;
  45.         for (i = 0; i < 4; i++) {
  46.                 start = 0 + range * i;
  47.                 if (i < 3) {
  48.                         end = start + range;
  49.                 } else {
  50.                         end = number;
  51.                 }
  52.                 message->lower = start;
  53.                 message->upper = end;
  54.                 pthread_create(&thread[i], NULL, countPrimeInRange, (void*) message);
  55.         }
  56.         return total;
  57. }

  59. JNIEXPORT jint JNICALL Java_com_fangzhaoguo_primefinder_NativePrimeFinder_countPrime__JJ(
  60.                 JNIEnv *env, jobject obj, jlong lower, jlong upper) {
  61.         jlong i = 0;
  62.         for (i = lower; i < upper; i++) {
  63.                 if (Java_com_fangzhaoguo_primefinder_NativePrimeFinder_isPrime(env, obj,
  64.                                 i)) {
  65.                         total++;
  66.                 }
  67.         }
  68.         return total;
  69. }
复制代码
但是现在的问题是在java中运行时报错，不管使用C写还是加载boost类的C++写，都报相同的错误。有不使用C/C++多线程的例子，可以正常使用
以下是报错内容
  1. Exception in thread "main" java.lang.UnsatisfiedLinkError: com.fangzhaoguo.primefinder.NativeConcurrentPrimeFinder.countPrime(J)I
  2.         at com.fangzhaoguo.primefinder.NativeConcurrentPrimeFinder.countPrime(Native Method)
  3.         at com.fangzhaoguo.primefinder.Main.timeAndCompute(Main.java:58)
  4.         at com.fangzhaoguo.primefinder.Main.main(Main.java:6)
复制代码
作者: weishuo1999    时间: 2013-07-20 23:58
看看是不是编译的原因，strings看一下你的函数名的符号有没有多个@符号，如果有的话，改一下编译参数
作者: 方兆国    时间: 2013-07-21 11:59
使用nm看吗？有下划线数量的变化，没有发现@
不过boost版的问题多些



欢迎光临 Chinaunix (http://bbs.chinaunix.net/) Powered by Discuz! X3.2