source/com/intellij/unscramble/ThreadState.java

   1 package com.intellij.unscramble;
   2
   3 import org.jetbrains.annotations.NonNls;
   4 import org.jetbrains.annotations.Nullable;
   5
   6 import java.util.ArrayList;
   7 import java.util.HashSet;
   8 import java.util.List;
   9 import java.util.Set;
  10
  11 /**
  12  * @author yole
  13  */
  14 public class ThreadState {
  15   private final String myName;
  16   private final String myState;
  17   private String myStackTrace;
  18   private boolean myEmptyStackTrace;
  19   private String myJavaThreadState;
  20   private String myThreadStateDetail;
  21   private String myExtraState;
  22   private final List<ThreadState> myThreadsWaitingForMyLock = new ArrayList<ThreadState>();
  23   private final Set<ThreadState> myDeadlockedThreads = new HashSet<ThreadState>();
  24
  25   @Nullable
  26   private ThreadOperation myOperation;
  27
  28   public ThreadState(final String name, final String state) {
  29     myName = name;
  30     myState = state.trim();
  31   }
  32
  33   public String getName() {
  34     return myName;
  35   }
  36
  37   public String getState() {
  38     return myState;
  39   }
  40
  41   public String getStackTrace() {
  42     return myStackTrace;
  43   }
  44
  45   public void setStackTrace(final String stackTrace, boolean isEmpty) {
  46     myStackTrace = stackTrace;
  47     myEmptyStackTrace = isEmpty;
  48   }
  49
  50   public String toString() {
  51     return myName;
  52   }
  53
  54   public void setJavaThreadState(final String javaThreadState) {
  55     myJavaThreadState = javaThreadState;
  56   }
  57
  58   public void setThreadStateDetail(@NonNls final String threadStateDetail) {
  59     myThreadStateDetail = threadStateDetail;
  60   }
  61
  62   public String getJavaThreadState() {
  63     return myJavaThreadState;
  64   }
  65
  66   public String getThreadStateDetail() {
  67     if (myOperation != null) {
  68       return myOperation.toString();
  69     }
  70     return myThreadStateDetail;
  71   }
  72
  73   public boolean isEmptyStackTrace() {
  74     return myEmptyStackTrace;
  75   }
  76
  77   public String getExtraState() {
  78     return myExtraState;
  79   }
  80
  81   public void setExtraState(final String extraState) {
  82     myExtraState = extraState;
  83   }
  84
  85   public boolean isSleeping() {
  86     return "sleeping".equals(getThreadStateDetail()) ||
  87            (("parking".equals(getThreadStateDetail()) || "waiting on condition".equals(myState)) && isThreadPoolExecutor());
  88   }
  89
  90   private boolean isThreadPoolExecutor() {
  91     return myStackTrace.contains("java.util.concurrent.ScheduledThreadPoolExecutor$DelayedWorkQueue.take") ||
  92            myStackTrace.contains("java.util.concurrent.ThreadPoolExecutor.getTask");
  93   }
  94
  95   public boolean isHoldingLock(ThreadState thread) {
  96     return myThreadsWaitingForMyLock.contains(thread);
  97   }
  98
  99   public void addWaitingThread(ThreadState thread) {
 100     myThreadsWaitingForMyLock.add(thread);
 101   }
 102
 103   public boolean isDeadlocked() {
 104     return !myDeadlockedThreads.isEmpty();
 105   }
 106
 107   public void addDeadlockedThread(ThreadState thread) {
 108     myDeadlockedThreads.add(thread);
 109   }
 110
 111   @Nullable
 112   public ThreadOperation getOperation() {
 113     return myOperation;
 114   }
 115
 116   public void setOperation(@Nullable final ThreadOperation operation) {
 117     myOperation = operation;
 118   }
 119
 120   public boolean isLocked() {
 121     return "on object monitor".equals(myThreadStateDetail) || "waiting on condition".equals(myState) ||
 122         ("parking".equals(myThreadStateDetail) && !isSleeping());
 123   }
 124
 125   public boolean isEDT() {
 126     return getName().startsWith("AWT-EventQueue");
 127   }
 128 }