lib/knj/process_meta.rb in knjrbfw-0.0.28 vs lib/knj/process_meta.rb in knjrbfw-0.0.29

@@ -392,11 +392,11 @@
     end
   end
   
   def initialize(args)
     @args = args
-    @_process_meta_buffer_use = false
+    @_process_meta_block_buffer_use = false
     ObjectSpace.define_finalizer(self, @args[:process_meta].method(:proxy_finalizer))
   end
   
   #This proxies all method-calls through the process-handeler and returns the result as the object was precent inside the current process-memory, even though it is not.
   def method_missing(method_name, *args, &block)
@@ -536,12 +536,16 @@
   
   def _pm_close
     self._pm_flush
     
     if @args[:async]
+      threads_remove = []
       @threads.each do |thread|
         thread.join
+        threads_remove << thread
       end
+      
+      @threads -= threads_remove
     end
     
     raise @raise_error if @raise_error
   end
 end
\ No newline at end of file