Handle unhandled exceptions for thread workers and enque a wrapped exception

1 files changed, 5 insertions, 1 deletions

diff --git a/lib/bundler/parallel_workers/thread_worker.rb b/lib/bundler/parallel_workers/thread_worker.rb
index 707e9f63b7..764b898e43 100644
--- a/lib/bundler/parallel_workers/thread_worker.rb
+++ b/lib/bundler/parallel_workers/thread_worker.rb
@@ -15,7 +15,11 @@ module Bundler
             loop do
               obj = @request_queue.deq
               break if obj.equal? POISON
-              @response_queue.enq func.call(obj)
+              begin
+                @response_queue.enq func.call(obj)
+              rescue Exception => e
+                @response_queue.enq(WrappedException.new(e))
+              end
             end
           end
         end