Examples of org.apache.avalon.excalibur.testcase.LatchedThreadGroup$Runner

Package org.apache.avalon.excalibur.testcase

Examples of org.apache.avalon.excalibur.testcase.LatchedThreadGroup$Runner

org.apache.avalon.excalibur.testcase.LatchedThreadGroup
This class is useful for writing MultiThreaded test cases where you need to perform multithreaded load testing on a component.
An instance of will create a block of threads of the specified size. Each thread will be assigned to run a specified Runnable instance. The threads will then all wait at a latch until the go method is called. The go method will not return until all of the Runnables have completed. @deprecated ECM is no longer supported @author Avalon Development Team @version $Id: LatchedThreadGroup.java,v 1.4 2004/02/28 11:47:27 cziegeler Exp $

        try { throw new Exception(); } catch(Exception ex) { name = ex.getStackTrace()[1].getMethodName(); }
        Method[] methods = getClass().getDeclaredMethods();
        Method m=null;
        for(int i=0; i<methods.length; i++) if (methods[i].getName().equals(name)) { m=methods[i]; break; }
        final Method method=m;
        return new Runner() {
            private static final long serialVersionUID = 0;
            public void run() {
                try {
                    method.setAccessible(true);
                    method.invoke(SimpleGUI.this, new Object[]{});

View Full Code Here

        try { throw new Exception(); } catch(Exception ex) { name = ex.getStackTrace()[1].getMethodName(); }
        Method[] methods = getClass().getDeclaredMethods();
        Method m=null;
        for(int i=0; i<methods.length; i++) if (methods[i].getName().equals(name)) { m=methods[i]; break; }
        final Method method=m;
        return new Runner() {
            private static final long serialVersionUID = 0;
            public void run(Object arg) {
                try {
                    method.setAccessible(true);
                    method.invoke(SimpleGUI.this, new Object[]{arg});

View Full Code Here

      try { throw new Exception(); } catch(Exception ex) { name = ex.getStackTrace()[1].getMethodName(); }
      Method[] methods = getClass().getDeclaredMethods();
      Method m=null;
      for(int i=0; i<methods.length; i++) if (methods[i].getName().equals(name)) { m=methods[i]; break; }
      final Method method=m;
      return new Runner() {
         private static final long serialVersionUID = 0;
         public void run() {
            try {
               method.setAccessible(true);
               method.invoke(VizGUI.this, new Object[]{});

View Full Code Here

      try { throw new Exception(); } catch(Exception ex) { name = ex.getStackTrace()[1].getMethodName(); }
      Method[] methods = getClass().getDeclaredMethods();
      Method m=null;
      for(int i=0; i<methods.length; i++) if (methods[i].getName().equals(name)) { m=methods[i]; break; }
      final Method method=m;
      return new Runner() {
         private static final long serialVersionUID = 0;
         public void run(Object arg) {
            try {
               method.setAccessible(true);
               method.invoke(VizGUI.this, new Object[]{arg});

View Full Code Here

                    fail( "IdGenerator returned duplicate ids." );
                }
            }
        };


        LatchedThreadGroup group = new LatchedThreadGroup( runnable, threadCount );
        group.enableLogging( getLogEnabledLogger() );


        // Run the test.
        long duration;
        try
        {
            duration = group.go();
        }
        catch( Throwable t )
        {
            // Throwable could have been thrown by one of the tests.
            if( m_throwable == null )

View Full Code Here

                    fail( "IdGenerator returned duplicate ids." );
                }
            }
        };


        LatchedThreadGroup group = new LatchedThreadGroup( runnable, threadCount );
        group.enableLogging( getLogEnabledLogger() );


        // Run the test.
        long duration;
        try
        {
            duration = group.go();
        }
        catch( Throwable t )
        {
            // Throwable could have been thrown by one of the tests.
            if( m_throwable == null )

View Full Code Here

        m_throwable = null;


        // Create the runnable
        MPoolRunner runnable = new MPoolRunner( pool, gets, m_logger );


        LatchedThreadGroup group = new LatchedThreadGroup( runnable, THREADS );
        group.enableLogging( m_logger );


        long duration;
        try
        {
            duration = group.go();
        }
        catch( Throwable t )
        {
            // Throwable could have been thrown by one of the tests.
            if( m_throwable == null )

View Full Code Here

        m_throwable = null;


        // Create the runnable
        PoolRunner runnable = new PoolRunner( pool, gets, m_logger );


        LatchedThreadGroup group = new LatchedThreadGroup( runnable, THREADS );
        group.enableLogging( m_logger );


        long duration;
        try
        {
            duration = group.go();
        }
        catch( Throwable t )
        {
            // Throwable could have been thrown by one of the tests.
            if( m_throwable == null )

View Full Code Here

TOP

Related Classes of org.apache.avalon.excalibur.testcase.LatchedThreadGroup$Runner

ch.ethz.vs.rowa.job.Job

co.arcs.groove.basking.task.SyncTask.Outcome

com.crawljax.core.configuration.CrawljaxConfiguration.CrawljaxConfigurationBuilder

com.crawljax.core.configuration.InputSpecification

com.crawljax.core.CrawljaxRunner

com.crawljax.core.plugin.descriptor.PluginDescriptor

com.crawljax.core.plugin.HostInterfaceImpl

com.facebook.presto.util.SetThreadName

com.google.gdata.data.BaseEntry

com.google.gdata.data.Entry

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.