2

我正在编写一个同时（并行）执行多个线程的程序，我正在使用 TaskExecutor 。

@Autowired TaskExecutor threadPoolTaskExecutor;
@Test
public  void testSpringTaskExecutor() 
                         throws InterruptedException  {
    assertNotNull(threadPoolTaskExecutor);
    for (int k = 0; k < 5; k++) {
        Runnable myThread = 
                        new Workflow(new AtomicInteger(k));
        threadPoolTaskExecutor.execute(myThread);
    }
    Thread.sleep(500);
    logger.info("Finished all threads");
}

当我测试我的代码时，引发了 AssertionError 异常。我正在使用 Spring Framework 来管理执行。

这是日志屏幕：

Exception in thread "main" java.lang.AssertionError
at org.junit.Assert.fail(Assert.java:92)
at org.junit.Assert.assertTrue(Assert.java:43)
at org.junit.Assert.assertNotNull(Assert.java:526)

任何人有任何想法请:)谢谢

4

1 回答 1

1

我找到了解决方案，我必须初始化 threadPoolTask​​Executor 所以当我们使用 assertNotNull(threadPoolTask​​Executor); 该对象将被初始化，我们可以执行我们的线程。

这是初始化方法：

 public void initialize() {
                     logger.info("Creating ThreadPoolExecutor");
                     BlockingQueue   queue = createQueue(this.queueCapacity);
                    executorService = new ThreadPoolExecutor  (
                             this.corePoolSize, this.maxPoolSize, this.keepAliveSeconds, TimeUnit.SECONDS,
                             queue, this.threadFactory, this.rejectedExecutionHandler);
                 }

这是 executorService 定义：

private ThreadPoolExecutor executorService;

谢谢安德鲁、佩斯和英戈的帮助:)

于 2013-03-21T13:05:38.627 回答