Attempt to use threading to control elbs

Author: edhgoose

lib/capify-ec2.rb

@@ -309,17 +309,25 @@ def deregister_instance_from_named_elbs_by_dns(server_dns, load_balancer_names)
     instance = get_instance_by_dns(server_dns)
 
     lbs = []
+    threads = []
+
     for load_balancer_name in load_balancer_names do
-      load_balancer = get_load_balancer_by_name(load_balancer_name)
+      threads << Thread.new({
+        load_balancer = get_load_balancer_by_name(load_balancer_name)
 
-      if load_balancer
-        puts "[Capify-EC2] Removing instance from named ELB '#{load_balancer.id}'..."
+        if load_balancer
+          puts "[Capify-EC2] Removing instance from named ELB '#{load_balancer.id}'..."
 
-        result = elb.deregister_instances_from_load_balancer(instance.id, load_balancer.id)
-        raise "Unable to remove instance from ELB '#{load_balancer.id}'..." unless result.status == 200
+          result = elb.deregister_instances_from_load_balancer(instance.id, load_balancer.id)
+          raise "Unable to remove instance from ELB '#{load_balancer.id}'..." unless result.status == 200
 
-        lbs << load_balancer
-      end
+          lbs << load_balancer
+        end
+      })
+    end
+
+    for t in threads do
+      t.join
     end
 
     lbs

lib/capify-ec2/capistrano.rb

@@ -176,15 +176,24 @@ def capify_ec2
           end
         end
 
+        threads = []
+
         for load_balancer_to_reregister in load_balancers_to_reregister do
-          puts "[Capify-EC2] Starting registration of ELB '#{load_balancer_to_reregister.id}'"
-          reregistered = capify_ec2.reregister_instance_with_elb_by_dns(server_dns, load_balancer_to_reregister, 60)
-          if reregistered
-            puts "[Capify-EC2] Instance registration with ELB '#{load_balancer_to_reregister.id}' successful.".green.bold
-          else
-            puts "[Capify-EC2] Instance registration with ELB '#{load_balancer_to_reregister.id}' failed!".red.bold
-            raise CapifyEC2RollingDeployError.new("ELB registration timeout exceeded", server_dns)
-          end
+          threads << Thread.new({
+            puts "[Capify-EC2] Starting registration of ELB '#{load_balancer_to_reregister.id}'"
+            
+            reregistered = capify_ec2.reregister_instance_with_elb_by_dns(server_dns, load_balancer_to_reregister, 60)
+            if reregistered
+              puts "[Capify-EC2] Instance registration with ELB '#{load_balancer_to_reregister.id}' successful.".green.bold
+            else
+              puts "[Capify-EC2] Instance registration with ELB '#{load_balancer_to_reregister.id}' failed!".red.bold
+              raise CapifyEC2RollingDeployError.new("ELB registration timeout exceeded", server_dns)
+            end  
+          })
+        end
+
+        for t in threads do
+          t.join
         end
 
         puts "[Capify-EC2] Deployment successful to #{instance_dns_with_name_tag(server_dns)}.".green.bold