- Timestamp:
- 09/10/13 21:11:41 (11 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
java/main/src/main/java/com/framsticks/util/dispatching/BufferedDispatcher.java
r102 r105 92 92 93 93 public void createThreadIfNeeded() { 94 if (targetDispatcher != null) { 95 return; 94 synchronized (this) { 95 if (targetDispatcher != null) { 96 return; 97 } 96 98 } 97 99 this.setTargetDispatcher(new Thread<C>().setName(parent.getName())); … … 104 106 105 107 @Override 106 protected void joinableStart() {108 protected synchronized void joinableStart() { 107 109 Dispatching.use(targetDispatcher, this); 108 110 } 109 111 110 112 @Override 111 protected void joinableInterrupt() {113 protected synchronized void joinableInterrupt() { 112 114 Dispatching.drop(targetDispatcher, this); 113 115 … … 121 123 122 124 @Override 123 protected void joinableJoin() throws InterruptedException {125 protected synchronized void joinableJoin() throws InterruptedException { 124 126 Dispatching.join(targetDispatcher); 125 127 }
Note: See TracChangeset
for help on using the changeset viewer.