Added stop() method to java object. (#555)

* Added stop() method to java object.

It breaks the internal indefinite loop and allows Node process to quit without SIGTERM.

 Solves bug #539 - The process refuses to quit.

* Moved start of default loop on first Java instance creation.

---------

Co-authored-by: jjuzna <[email protected]>

Author: jjuzna

src/java.cpp

@@ -22,6 +22,7 @@
 #endif
 
 threadId v8ThreadId;
+bool isDefaultLoopRunning = false;
 
 std::queue<DynamicProxyJsCallData *> queue_dynamicProxyJsCallData;
 uv_mutex_t uvMutex_dynamicProxyJsCall;
@@ -78,9 +79,9 @@ void uvAsyncCb_dynamicProxyJsCall(uv_async_t *handle) {
   Nan::HandleScope scope;
 
   v8ThreadId = my_getThreadId();
+  isDefaultLoopRunning = false; //init as false
 
   uv_mutex_init(&uvMutex_dynamicProxyJsCall);
-  uv_async_init(uv_default_loop(), &uvAsync_dynamicProxyJsCall, uvAsyncCb_dynamicProxyJsCall);
 
   v8::Local<v8::FunctionTemplate> t = Nan::New<v8::FunctionTemplate>(New);
   s_ct.Reset(t);
@@ -106,6 +107,7 @@ void uvAsyncCb_dynamicProxyJsCall(uv_async_t *handle) {
   Nan::SetPrototypeMethod(t, "getStaticFieldValue", getStaticFieldValue);
   Nan::SetPrototypeMethod(t, "setStaticFieldValue", setStaticFieldValue);
   Nan::SetPrototypeMethod(t, "instanceOf", instanceOf);
+  Nan::SetPrototypeMethod(t, "stop", stop);
 
   Nan::Set(target, Nan::New<v8::String>("Java").ToLocalChecked(), Nan::GetFunction(t).ToLocalChecked());
 
@@ -115,6 +117,11 @@ void uvAsyncCb_dynamicProxyJsCall(uv_async_t *handle) {
 NAN_METHOD(Java::New) {
   Nan::HandleScope scope;
 
+  if (!isDefaultLoopRunning) {
+    uv_async_init(uv_default_loop(), &uvAsync_dynamicProxyJsCall, uvAsyncCb_dynamicProxyJsCall);
+    isDefaultLoopRunning = true;
+  }
+
   Java *self = new Java();
   self->Wrap(info.This());
 
@@ -1239,6 +1246,12 @@ NAN_METHOD(Java::instanceOf) {
   info.GetReturnValue().Set(Nan::New<v8::Boolean>(res));
 }
 
+NAN_METHOD(Java::stop) {
+  if (isDefaultLoopRunning) {
+    uv_close((uv_handle_t *)&uvAsync_dynamicProxyJsCall, NULL);
+  }
+}
+
 template <typename T>
 std::string to_string(T value) {
   std::ostringstream os;

src/java.h

@@ -56,6 +56,7 @@ class Java : public Nan::ObjectWrap {
   static NAN_METHOD(getStaticFieldValue);
   static NAN_METHOD(setStaticFieldValue);
   static NAN_METHOD(instanceOf);
+  static NAN_METHOD(stop);
   static NAN_GETTER(AccessorProhibitsOverwritingGetter);
   static NAN_SETTER(AccessorProhibitsOverwritingSetter);
   v8::Local<v8::Value> ensureJvm();