- Timestamp:
- 07/12/13 23:41:06 (11 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
java/main/src/main/java/com/framsticks/util/dispatching/Dispatching.java
r99 r100 1 1 package com.framsticks.util.dispatching; 2 2 3 import org.apache.log4j.Logger; 3 import org.apache.logging.log4j.Logger; 4 import org.apache.logging.log4j.LogManager; 4 5 5 6 import com.framsticks.util.FramsticksException; … … 9 10 */ 10 11 public abstract class Dispatching { 11 private static final Logger log = Log ger.getLogger(Dispatching.class);12 private static final Logger log = LogManager.getLogger(Dispatching.class); 12 13 13 14 public static boolean isThreadSafe() { … … 57 58 58 59 public static void use(final Joinable joinable, final JoinableParent owner) { 59 log.debug("using " + joinable + " by " +owner);60 log.debug("using {} by {}", joinable, owner); 60 61 if (joinable.use(owner)) { 61 log.debug("started " +joinable);62 log.debug("started {}", joinable); 62 63 } else { 63 log.debug("start of " + joinable + " already happened");64 log.debug("start of {} already happened", joinable); 64 65 } 65 66 } 66 67 67 68 public static void drop(final Joinable joinable, final JoinableParent owner) { 68 log.debug("droping " + joinable + " by " +owner);69 log.debug("droping {} by {}", joinable, owner); 69 70 if (joinable.drop(owner)) { 70 log.debug("stoped " +joinable);71 log.debug("stoped {}", joinable); 71 72 } else { 72 log.debug("stop of " + joinable + " deferred");73 log.debug("stop of {} deferred", joinable); 73 74 } 74 75 } 75 76 76 77 public static void join(Joinable joinable) throws InterruptedException { 77 log.debug("joining " +joinable);78 log.debug("joining {}", joinable); 78 79 try { 79 80 joinable.join(); 80 81 } catch (InterruptedException e) { 81 log.debug("failed to join " +joinable);82 log.debug("failed to join {}", joinable); 82 83 throw e; 83 84 } 84 log.debug("joined " +joinable);85 log.debug("joined {}", joinable); 85 86 } 86 87 … … 92 93 @Override 93 94 protected void runAt() { 94 log.debug("joinable " + joinable + " is notifying parent " + parent + " about change to " +state);95 log.debug("joinable {} is notifying parent {} about change to {}", joinable, parent, state); 95 96 parent.childChangedState(joinable, state); 96 97 } … … 108 109 109 110 public static void joinAbsolutely(Joinable joinable) { 110 log.debug("joining absolutely " +joinable);111 log.debug("joining absolutely {}", joinable); 111 112 while (true) { 112 113 try { … … 116 117 // throw new FramsticksException().msg("failed to join").arg("dispatcher", dispatcher).cause(e); 117 118 } 118 log.debug("waiting for " +joinable);119 log.debug("waiting for {}", joinable); 119 120 wait(joinable, 500); 120 121 }
Note: See TracChangeset
for help on using the changeset viewer.