- Timestamp:
- 06/24/13 13:38:40 (11 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
java/main/src/main/java/com/framsticks/core/LocalInstance.java
r84 r85 13 13 import java.util.HashSet; 14 14 import java.util.Set; 15 import com.framsticks.util.dispatching.RunAt; 15 16 16 17 … … 33 34 acceptSocket = new ServerSocket(); 34 35 acceptSocket.setReuseAddress(true); 35 acceptThread = new Thread (name + "-accept");36 acceptThread = new Thread<Accept>(name + "-accept").start(); 36 37 tryBind(accept); 37 38 } catch (IOException e) { … … 43 44 protected final Set<InstanceClient> clients = new HashSet<InstanceClient>(); 44 45 ServerSocket acceptSocket; 45 Thread acceptThread; 46 47 public static class Accept { 48 }; 49 50 Thread<Accept> acceptThread; 46 51 47 52 protected void acceptNext() { 48 acceptThread.invokeLater(new Run nable() {53 acceptThread.invokeLater(new RunAt<Accept>() { 49 54 @Override 50 55 public void run() { … … 53 58 assert socket != null; 54 59 log.debug("accepted socket: " + socket.getInetAddress().getHostAddress()); 55 invokeLater(new Run nable() {60 invokeLater(new RunAt<LocalInstance>() { 56 61 @Override 57 62 public void run() { … … 70 75 71 76 public void tryBind(final Integer accept) { 72 acceptThread.invokeLater(new Run nable() {77 acceptThread.invokeLater(new RunAt<Accept>() { 73 78 @Override 74 79 public void run() {
Note: See TracChangeset
for help on using the changeset viewer.