Сканер многопоточного порта Java

Question

Попытка заставить его двигаться быстрее, чем сейчас. это супер медленно, нити, похоже, не идут в одно и то же время, не могу понять это. Если бы кто-нибудь мог помочь описать, где моя проблема, чтобы я мог понять, как это сделать быстрее, я бы очень признателен, спасибо вам большое!

package infoGrabber; 

import java.awt.List; 
import java.io.IOException; 
import java.net.Socket; 
import java.util.Scanner; 

public class infoMain { 

    public static int port; 

    @SuppressWarnings("resource") 
    public static void main(String[] args) { 
     System.out.println("What host do you want to lookup?: "); 
     Scanner userEntry = new Scanner(System.in); 
     String host = userEntry.nextLine(); 

     try { 
      startThreads(host); 
     } catch (InterruptedException e) { 
      e.printStackTrace(); 
     } 

    } 

    private static void startThreads(String host) throws InterruptedException { 
     int numThreads = 10; 
     int count = 10; 
     Thread[] threads = new Thread[numThreads]; 
     System.out.println("Creating threads"); 
     for (int i = 0; i < threads.length; i++) { 
      threads[i] = new Thread(new Runner(host, count)); 
      threads[i].start(); 
      threads[i].join(); 
     } 
     System.out.println("Done"); 
    } 
} 

class Runner implements Runnable { 
    static int port; 
    private final String host; 
    private final int count; 
    infoMain main = new infoMain(); 

    public Runner(String host, int count) { 
     this.host = host; 
     this.count = count; 
    } 

    public void run() { 
     for (int port = 0; port < 2000; port++) { 
      // System.out.println(name + "=" + i + "\n"); 
      Socket socket; 
       try { 
        socket = new Socket(host, port);// Attempt to establish a socket on port i. 
        // If no IOException thrown, there must 
        // be a service running on the port. 
        System.out.println("Port " + port + " is open."); 
        socket.close(); 
       } catch (IOException ioEx) { 
        System.out.println("Port " + port + " is not open."); 
       }// No server on this port 
      } 
      Thread.yield(); 
     } 
    } 

Answer 1

Вы не разделяете работу между потоками. Вместо этого вы даете каждому потоку столько же работы, как и в основной поток в последовательной программе. Вы должны разделить работу между вашими потоками, чтобы увеличить скорость выполнения.

Ваш цикл должен выглядеть примерно так:

for (int i = 0; i < threads.length; i++) { 
    threads[i] = new Thread(new Runner(host, count * NUMBER_OF_PORTS_PER_THREAD)); 
    threads[i].start(); 

} 

// Join threads after you created them 
// All credits for @biziclop for spotting this 
for (int i = 0; i < threads.length; i++) { 
    threads[i].join(); 
} 

И вы Runnable код должен выглядеть примерно так:

class Runner implements Runnable { 

final private int startPort; 

public Runner(String host, int startPort) { 
     this.host = host; 
     this.startPort = startPort; 
    } 

    public void run() { 
     for (int port = startPort; port <= NUMBER_OF_PORTS_PER_THREAD + startPort; port++) { 
     ... 
    } 
} 

где NUMBER_OF_PORTS_PER_THREAD должен быть равен 200 для сканирования портов 2000 с 10 нитями.