Futures for Multithreading을 사용하는 방법?

Question

저는 Scala를 처음 사용합니다. 스칼라에서 멀티 스레딩을 배우고 있습니다. Scala에서 멀티 스레딩의 한 가지 방법은 scala.actors이지만 요즘에는 사용되지 않습니다. 따라서 새로운 방법은 scala.concurrent 또는 akka.actor을 사용하는 것입니다. scala.concurrent을 사용하고 싶습니다. 시나리오 : 여러 클라이언트의 연결을 동시에 허용하고 다시 응답하는 채팅 서버를 만들고 싶습니다. 내가하려고 방법은 다음과 같습니다

는

while(true) { 
     socket = serverSocket.accept() 
     os = new PrintStream(socket.getOutputStream) 
     br = new BufferedReader(new InputStreamReader(socket.getInputStream())) 

     val newClient = Future { 
     os.println("\n\nPlease Enter the Table name to be Extracted\t:") 
     restr = br.readLine() 

     println("data received from ["+socket.getInetAddress()+"] ["+socket.getPort()+"] and TableName ["+ restr +"]\n") 
     new Extractor().extract(dbURL,userId,password,restr,os) 
     } 
    val clientFormed= newClient.isCompleted 
     println("New Client Connection ? ["+clientFormed+"]") 
    } 

하지만, 프로그램을 실행 한 후 출력은 말한다 :

New Response made [false] 

는 선물이 실행되지 않았 음을 의미합니다. 잠도 작동하지 않습니다. 나는 여기에 뭔가 부족한 것을 알고 있지만 알아낼 수는 없다.

UPDATE 나는 (사실) 미래의 내부 것은 올바른 방법이 아니다 동안 알고 있지만 진정한 동안은 서버의 지속적인 실행을 위해 필요하다. 나는 내 길을 잘못 알고있다. 내가 원하는 것은 그것을하는 올바른 방법은 무엇입니까?

Answer 1

response은 앞으로 while(true)으로 시작하는 미래입니다. 그것이 완료 될 수있는 방법은 없습니다.