Examples of ThreadInfo


Examples of de.danet.an.workflow.internalapi.ThreadInfo

     * deferred choice, reset all other (competing) activities.
     * @param act the activity
     */
    public void resetCompeting (ExtActivityLocal act)
  throws TransitionNotAllowedException {
  ThreadInfo threadInfo = act.threadInfo ();
  Collection res = new ArrayList ();
  Collection predecessors = (Collection)transByTo.get(act.key());
  if (predecessors.size() == 0) {
      throw new IllegalArgumentException
    (act + " has no predecessors, cannot be preliminarily chosen");
  }
  for (Iterator i = predecessors.iterator(); i.hasNext ();) {
      ExtTransitionLocal trans = (ExtTransitionLocal)i.next();
      ExtActivityLocal fromAct = (ExtActivityLocal)trans.from();
      if (fromAct.deferChoiceOnSplit ()
    && threadInfo.includes (fromAct.key())) {
    for (Iterator j = ((Collection)transByFrom.get(fromAct.key()))
       .iterator(); j.hasNext ();) {
        ExtTransitionLocal ft = (ExtTransitionLocal)j.next();
        res.add (ft.to());
                    ft.setPendingToken(false);
View Full Code Here

Examples of de.danet.an.workflow.internalapi.ThreadInfo

    ("Cannot update not started substate, activity is "
     + getPaTypedState().toString());
  }
  setPaTypedState (NotStartedState.STARTABLE);
  if (getPaThreadInfo() == null) {
      setPaThreadInfo (new ThreadInfo (triggers));
  }
  setPaPreliminarilyChosen (preliminarilyChosen);
  if (logger.isDebugEnabled ()) {
      logger.debug (toString () + " triggered by " + getPaThreadInfo ());
  }
View Full Code Here

Examples of de.danet.an.workflow.internalapi.ThreadInfo

  throw new UnsupportedOperationException ();
    }

    /* Comment copied from interface. */
    public ThreadInfo threadInfo () {
  return new ThreadInfo (null);
    }
View Full Code Here

Examples of gov.nasa.jpf.vm.ThreadInfo

  protected int computeHeuristicValue() {
    int heuristicValue = -1;
    int currentJointStatesDepth = getJointStatesDepth();
    int nextJointStatesDepth = currentJointStatesDepth + 1;

    ThreadInfo ti = this.vm.getCurrentThread();
    Object attr = null;

    if (ti != null) {
      if (ti.getPC() != null) {
        attr = ti.getPC().getAttr();
      }
    }

    // The state is a joint state
    if (attr != null) {
View Full Code Here

Examples of java.lang.management.ThreadInfo

        StringBuilder sb=new StringBuilder();
        ThreadMXBean bean=ManagementFactory.getThreadMXBean();
        long[] ids=bean.getAllThreadIds();
        ThreadInfo[] threads=bean.getThreadInfo(ids, 20);
        for(int i=0; i < threads.length; i++) {
            ThreadInfo info=threads[i];
            if(info == null)
                continue;
            sb.append(info.getThreadName()).append(":\n");
            StackTraceElement[] stack_trace=info.getStackTrace();
            for(int j=0; j < stack_trace.length; j++) {
                StackTraceElement el=stack_trace[j];
                sb.append("    at ").append(el.getClassName()).append(".").append(el.getMethodName());
                sb.append("(").append(el.getFileName()).append(":").append(el.getLineNumber()).append(")");
                sb.append("\n");
View Full Code Here

Examples of java.lang.management.ThreadInfo

        }
       
        new_times.put( id, time );
      }
     
      ThreadInfo  info = bean.getThreadInfo( ids[biggest_index ]);

      String  thread_name = info==null?"<dead>":info.getThreadName();
     
      int  percent = (int)( 100*biggest_diff / time_available );
     
      Runtime rt = Runtime.getRuntime();
     
      log.log( "Thread state: elapsed=" + elapsed + ",cpu=" + total_diffs + ",max=" + thread_name + "(" + biggest_diff + "/" + percent + "%),mem:max=" + (rt.maxMemory()/1024)+",tot=" + (rt.totalMemory()/1024) +",free=" + (rt.freeMemory()/1024));
     
      if ( biggest_diff > time_available/4 ){
       
        info = bean.getThreadInfo( ids[biggest_index ], 255 );
       
        if ( info == null ){
         
          log.log( "    no info for max thread" );
         
        }else{
         
          StackTraceElement[] elts = info.getStackTrace();
          StringBuilder str = new StringBuilder(elts.length * 20);
         
          str.append("    ");
          for (int i=0;i<elts.length;i++){
            if(i != 0)
View Full Code Here

Examples of java.lang.management.ThreadInfo

    writer.println("Threads " + allThreadIds.length);
    writer.indent();

    List<ThreadInfo> threadInfos = new ArrayList<ThreadInfo>(allThreadIds.length);
    for (int i = 0; i < allThreadIds.length; i++) {
      ThreadInfo info = threadBean.getThreadInfo(allThreadIds[i], 32);
      if(info != null)
        threadInfos.add(info);
    }

    if (!disable_getThreadCpuTime) {
      Collections.sort(threadInfos, new Comparator<ThreadInfo>() {
        public int compare(ThreadInfo o1, ThreadInfo o2) {
         
          long diff = threadBean.getThreadCpuTime(o2.getThreadId())
              - threadBean.getThreadCpuTime(o1.getThreadId());
          if (diff == 0) {
            return o1.getThreadName().compareToIgnoreCase(o2.getThreadName());
          }
          return diff > 0 ? 1 : -1;
        }
      });
    }

    for (int i = 0; i < threadInfos.size(); i++) {
      try {
        ThreadInfo threadInfo = threadInfos.get(i);

        long lCpuTime = disable_getThreadCpuTime ? -1
            : threadBean.getThreadCpuTime(threadInfo.getThreadId());
        if (lCpuTime == 0)
          break;

        String sState;
        switch (threadInfo.getThreadState()) {
          case BLOCKED:
            sState = "Blocked";
            break;
          case RUNNABLE:
            sState = "Runnable";
            break;
          case NEW:
            sState = "New";
            break;
          case TERMINATED:
            sState = "Terminated";
            break;
          case TIMED_WAITING:
            sState = "Timed Waiting";
            break;

          case WAITING:
            sState = "Waiting";
            break;

          default:
            sState = "" + threadInfo.getThreadState();
            break;

        }

        String sName = threadInfo.getThreadName();
        String sLockName = threadInfo.getLockName();

        writer.println(sName
            + ": "
            + sState
            + ", "
            + (lCpuTime / 1000000)
            + "ms CPU, "
            + "B/W: "
            + threadInfo.getBlockedCount()
            + "/"
            + threadInfo.getWaitedCount()
            + (sLockName == null ? "" : "; Locked by " + sLockName + "/"
                + threadInfo.getLockOwnerName()));

        writer.indent();
        try {
          StackTraceElement[] stackTrace = threadInfo.getStackTrace();
          for (int j = 0; j < stackTrace.length; j++) {
            writer.println(stackTrace[j].toString());
          }
        } finally {
          writer.exdent();
View Full Code Here

Examples of java.lang.management.ThreadInfo

      MetaValue tid0InfoMV = getThreadInfo.invoke(tid0SV);
      assertNotNull(tid0InfoMV);
      assertTrue(tid0InfoMV instanceof CompositeValue);
      log.debug(tid0InfoMV);
      CompositeValue tid0InfoCV = (CompositeValue) tid0InfoMV;
      ThreadInfo tid0Info = ManagementFactoryUtils.unwrapThreadInfo(tid0InfoCV);
      log.debug(tid0Info);
   }
View Full Code Here

Examples of java.lang.management.ThreadInfo

      long[] threads = threadMXBean.getAllThreadIds();
      for (int i = 0; i < threads.length; ++i)
      {
         Long id = new Long(threads[i]);
         Long cpuTime = threadMXBean.getThreadCpuTime(id);
         ThreadInfo threadInfo = threadMXBean.getThreadInfo(id, ZERO );
         if (threadInfo != null)
         {
            String name = threadInfo.getThreadName();
            result.add(new ThreadCPU(name, cpuTime.longValue()));
         }
      }
      return result;
   }
View Full Code Here

Examples of java.lang.management.ThreadInfo

   {
      // Get the threadId
      Long threadId = thread.getId();

      // Get the ThreadInfo object for that threadId, max StackTraceElement depth
      ThreadInfo threadInfo = threadMXBean.getThreadInfo(threadId, new Integer(Integer.MAX_VALUE));
     
      outputJdk5ThreadMXBeanInfo(sbuf, threadInfo);     
   }
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.