Hilos en Ruby (by sh4van3)

array=['hola', 'esto', 'es', 'un', 'ejemplo'] # Creamos un array de 5 elementos.

hilo=Array.new # Creamos un array para los hilos. Ser? de 5 elementos y cada uno de ellos sera un hilo(Esto lo veremos a continuaci?n ;))


for element in array #creamos un bloque
	hilo<<Thread.new(element){|x| # Creamos un hilo para cada elemento y lo introducimos en el array hilo.
	puts x # Hacemos que imprima por pantalla x
	}
end

hilo.each{|z| z.join} # Con este ultimo comando, nos aseguramos de que los hilos no mueran antes de que finalize el programa principal (luego se explicar? esto m?s detenidamente).

array=['hola', 'esto', 'es', 'un', 'ejemplo']

hilo= Array.new

array.each{|element|
	hilo<<Thread.new(element){|x|
	puts x
	}
}

hilo.each{|ele| ele.join}

require 'socket'

paginas=['www.code-makers.es', 'www.google.com', 'www.youtube.com'] #Creamos el array con las 3 p?ginas.

hilo=Array.new

for pag in paginas
	hilo<<Thread.new(pag){|x|
	begin
	TCPSocket.new(x, 21)
	rescue 
	puts "21 cerrado en #{x}"
	else
	puts "21 abierto en #{x}"
	end
	sleep 1 #Damos un peque?o espacio de tiempo para que se termine el proceso.
	begin
	TCPSocket.new(x, 80)
	rescue
	puts "80 cerrado en #{x}"
	else
	puts "80 abierto en #{x}"
	end
	sleep 1
	begin
	TCPSocket.new(x, 81)
	rescue
	puts "81 cerrado en #{x}"
	else
	puts "81 abierto en #{x}"
	end
	}
end

hilo.each{|ele| ele.join}

Thread.current # Nos devuelve el hilo que esta siendo ejecutado "<Thread:0x401bdf4c run>"
Thread.list # Nos devuelve un array con los objetos para cada hilo diciendonos si estan corriendo o parados.
   #<Thread:0x401b3e84 sleep>
   #<Thread:0x401b3f38 run>
   #<Thread:0x401b3fb0 sleep>
   #<Thread:0x401bdf4c run>
hilo.status # Nos devuelve el estatus del hilo. "run", "sleep", "aborting"
Thread.kill(hilo) # Acaba con el proceso.
Thread.start{|x| bloque} # Igual que Thread.new.
Thread.stop # Deja durmiendo al hilo pero no lo mata.
hilo.join # Cuando un programa en Ruby termina, los hilos en ejecuci?n se matan independientemente de su estado. 
#Con join lo que hacemos es esperar a que termine el hilo antes de matarlos. Digamos que con join te aseguras de que se realicen todos los procesos.

count = 0
arr = []
10.times do |i|
  arr[i] = Thread.new {
    sleep(rand(0)/10.0)
    Thread.current["mycount"] = count # Asignamos la variable count a la llave del hash "mycount", que se guarda en hilo.
    count += 1
  }
end
arr.each {|t| t.join; print t["mycount"], ", " }
puts "count = #{count}"

require 'socket'

paginas=['www.code-makers.es', 'www.google.com', 'www.youtube.com'] #Creamos el array con las 3 p?ginas.

hilo=Array.new

for pag in paginas
	hilo<<Thread.new(pag){|x|
	begin
	TCPSocket.new(x, 80)
	rescue 
	a= "80 cerrado en #{x}"
	else
	a= "80 abierto en #{x}"
	end
	}
end

hilo.each{|ele| ele.join}
puts a

require 'socket'

paginas=['www.code-makers.es', 'www.google.com', 'www.youtube.com'] #Creamos el array con las 3 p?ginas.

hilo=Array.new

for pag in paginas
	hilo<<Thread.new(pag){|x|
	begin
	TCPSocket.new(x, 80)
	rescue 
	a= "80 cerrado en #{x}"
	else
	a= "80 abierto en #{x}"
	end
	Thread.current["#{x}"]=a # Asignamos la variable <a> a la llave del hash x (que ser? la p?gina web que se est? escaneando en ese momento), y la guardamos en hilo.
	}
end

hilo.each{|ele| ele.join; puts ele["www.code-makers.es"]}