如何在Java中創建事件

Question

我目前正在研究一個基於多線程的基於Java的程序，它應該允許多個線程向該程序發送請求。這應該與事件激活一起處理，但我很難理解事件及其實現。下面是允許多個線程與程序進行通信的代碼，但我只有一個線程。有人可以提供更多的信息嗎？非常感激。

//this is a a threads class 
import java.io.BufferedOutputStream; 
import java.io.BufferedReader; 
import java.io.IOException; 
import java.io.InputStreamReader; 
import java.net.Socket; 
import java.util.logging.Level; 
import java.util.logging.Logger; 


public class Niti implements Runnable { 

    public String line; 
    public Socket soc; 
    public boolean active=true; 

    public Niti(Socket soc) 
    { 
     this.soc=soc; 
     this.line=line; 
     this.active=active; 
    } 


    public synchronized void run() { 
     try { 
      BufferedReader br = new BufferedReader(new InputStreamReader(soc.getInputStream())); 
      line=br.readLine(); 
      while(line!=null && !line.equals("")){ 

       if(!this.active) 
        break; 

       System.out.println(line); 
       line=br.readLine(); 
      } 

      BufferedOutputStream bos = new BufferedOutputStream(soc.getOutputStream()); 
      bos.write("Poruka iz Programa".getBytes()); 

     } 
     catch (IOException ex) { 
      Logger.getLogger(Niti.class.getName()).log(Level.SEVERE, null, ex); 
     } 
     try {   
      soc.close(); 

     } catch (IOException ex) { 
      Logger.getLogger(Niti.class.getName()).log(Level.SEVERE, null, ex); 
     } 
    } 
} 



import java.io.BufferedOutputStream; 
import java.io.BufferedReader; 
import java.io.IOException; 
import java.io.InputStreamReader; 
import java.net.ServerSocket; 
import java.net.Socket; 


//and this is the main class 
public class Server{ 


    public static synchronized void main(String[] args) throws IOException, InterruptedException{ 

     ServerSocket ss = new ServerSocket(1000); 

     while(true){ 
      Socket sokit = ss.accept(); 
      Niti n = new Niti(sokit); 
      while(true){ 

       Thread t = new Thread(n); 
       t.start(); 

       //Thread.sleep(4000); 
       //n.active=false; 
       System.out.println("nit broj:" + Thread.currentThread().getId()); 
      } 
     } 
    } 
} 

Answer 1

好了，沒有看向鎳鈦類（即我想在客戶端處理程序類），你有一個邏輯錯誤的位置：

while(true){ 
     Socket sokit = ss.accept(); 
     Niti n = new Niti(sokit); 
     while(true){ // LOGIC ERROR!!! 

      Thread t = new Thread(n); 
      t.start(); 

      //Thread.sleep(4000); 
      //n.active=false; 
      System.out.println("nit broj:" + Thread.currentThread().getId()); 
     } 
    } 

你創造傳球后無窮遠線程上面的代碼第一次通過接受方法。你需要做的是刪除第二個（true），像這樣：

while(true){ 
     Socket sokit = ss.accept(); 
     Niti n = new Niti(sokit); 

     Thread t = new Thread(n); 
     t.start(); 

     //Thread.sleep(4000); 
     //n.active=false; 
     System.out.println("nit broj:" + Thread.currentThread().getId());    
    }