com.mapd.tests.ConcurrencyTest.MonitoringThread Class Reference

Inheritance diagram for com.mapd.tests.ConcurrencyTest.MonitoringThread:

Collaboration diagram for com.mapd.tests.ConcurrencyTest.MonitoringThread:

Public Member Functions
void	run ()

Package Functions
	MonitoringThread (List< SqlCommandThread[]> monitoredThreads, int numThreads)

Package Attributes
List< SqlCommandThread[]>	monitoredThreads
int	numThreads

Detailed Description

Definition at line 198 of file ConcurrencyTest.java.

Constructor & Destructor Documentation

com.mapd.tests.ConcurrencyTest.MonitoringThread.MonitoringThread ( List< SqlCommandThread[]>  monitoredThreads, int  numThreads  )

inlinepackage

Definition at line 202 of file ConcurrencyTest.java.

References com.mapd.tests.ConcurrencyTest.MonitoringThread.monitoredThreads, and com.mapd.tests.ConcurrencyTest.MonitoringThread.numThreads.

                                                                                {
      this.monitoredThreads = monitoredThreads;
      this.numThreads = numThreads;
    }

Member Function Documentation

void com.mapd.tests.ConcurrencyTest.MonitoringThread.run ( )

inline

Definition at line 208 of file ConcurrencyTest.java.

References com.mapd.tests.ConcurrencyTest.MonitoringThread.monitoredThreads, and com.mapd.tests.ConcurrencyTest.MonitoringThread.numThreads.

                      {
      int finishedThreads = 0;
      int totalThreads = monitoredThreads.size() * numThreads;
      while (finishedThreads < totalThreads) {
        finishedThreads = 0;
        for (SqlCommandThread threadGroup[] : monitoredThreads) {
          for (SqlCommandThread thread : threadGroup) {
            if (thread.getState() == Thread.State.TERMINATED) {
              finishedThreads++;
            }
          }
        }
        logger.info("Threads running: " + (totalThreads - finishedThreads));
        try {
          Thread.sleep(60000);
        } catch (Exception e) {
          logger.error("Monitoring thread: " + e.getMessage());
        }
      }
    }

Member Data Documentation

List<SqlCommandThread[]> com.mapd.tests.ConcurrencyTest.MonitoringThread.monitoredThreads

package

Definition at line 199 of file ConcurrencyTest.java.

Referenced by com.mapd.tests.ConcurrencyTest.MonitoringThread.MonitoringThread(), and com.mapd.tests.ConcurrencyTest.MonitoringThread.run().

int com.mapd.tests.ConcurrencyTest.MonitoringThread.numThreads

package

Definition at line 200 of file ConcurrencyTest.java.

Referenced by com.mapd.tests.ConcurrencyTest.MonitoringThread.MonitoringThread(), and com.mapd.tests.ConcurrencyTest.MonitoringThread.run().

---

The documentation for this class was generated from the following file:

• /home/jenkins-slave/workspace/core-os-doxygen/java/utility/src/main/java/com/mapd/tests/ConcurrencyTest.java