Java框架中并发编程的测试方法和注意事项（jav

import java.util.concurrent.ConcurrentLinkedQueue; zvvq.cn

import org.junit.Test;

内容来自samhan666

import org.mockito.Mockito;

内容来自samhan666

public class QueueTest { 内容来自zvvq，别采集哟

@Test

public void testConcurrency() throws InterruptedException {

内容来自samhan666

ConcurrentLinkedQueue<Integer> queue = Mockito.mock(ConcurrentLinkedQueue.class); copyright zvvq

Thread[] threads = new Thread[5]; zvvq

for (int i = 0; i < threads.length; i++) { zvvq.cn

threads[i] = new Thread(() -> {

for (int j = 0; j < 1000; j++) { zvvq.cn

queue.offer(j); zvvq

}

zvvq.cn

}); 本文来自zvvq

threads[i].start(); zvvq.cn

}

copyright zvvq

for (Thread thread : threads) { 内容来自zvvq，别采集哟

thread.join(); 内容来自zvvq

} 内容来自samhan666

Mockito.verify(queue, Mockito.times(5000)).offer(Mockito.anyInt());

} copyright zvvq

} zvvq

import java.util.concurrent.CountDownLatch; 内容来自zvvq，别采集哟

import java.util.concurrent.TimeUnit;

zvvq

import org.testng.annotations.Test;

public class QueueIntegrationTest { 本文来自zvvq

@Test

内容来自zvvq

public void testPerformance() throws InterruptedException { 内容来自samhan

ConcurrentLinkedQueue<Integer> queue = new ConcurrentLinkedQueue<>(); zvvq

CountDownLatch latch = new CountDownLatch(1);

copyright zvvq

Thread producer = new Thread(() -> { 内容来自samhan666

for (int i = 0; i < 1000000; i++) {

本文来自zvvq

queue.offer(i); 内容来自zvvq

}

latch.countDown();

zvvq好，好zvvq

});

zvvq

Thread consumer = new Thread(() -> {

内容来自samhan666

try {

内容来自samhan666

latch.await(10, TimeUnit.SECONDS);

} catch (InterruptedException e) {

zvvq

e.printStackTrace(); copyright zvvq

}

while (!queue.isEmpty()) { 本文来自zvvq

queue.poll(); 内容来自zvvq，别采集哟

}

zvvq.cn

}); zvvq好，好zvvq

producer.start(); 内容来自samhan666

consumer.start(); zvvq好，好zvvq

producer.join(); zvvq好，好zvvq

consumer.join();

System.out.println("Average throughput: " + (1000000 / 10) + " items/second"); 内容来自samhan

}

} zvvq.cn