Delay queue performance test

In previous performance tests , Delay queue is used

java.util.concurrent.DelayQueue

The function of

Order delay 10s Cancellation performance test

, In fact, it is also simple to use the basic API, The demonstration is as follows

DelayQueue Basic function demonstration

. In the face of Java & Go The delay queue cannot be included in the performance comparison test plan of various queues . At that time, I felt that this queue was designed to have a lot of sorting , And the queue realized by array , Combined with the

java.util.concurrent.ArrayBlockingQueue

Performance data of the queue , So I think the performance of delay queue is poor , Gave up doing comparative tests .

I've been watching recently

goreplay

After the project data of , It's very interesting to find this real traffic playback , It is to judge whether to send the request immediately according to the timestamp of the request . This is for different pressure measurement scenarios , It better matches the fluctuation of online traffic （ The best effect for fluctuating scenes ）. You can also find more existing performance bottlenecks and risk items .

So , I'm going to give full play to my copying ability again , hold goreplay Copy this function , Just use

java.util.concurrent.DelayQueue

As a message queue implementation class .

Conclusion

java.util.concurrent.Delayed

Own performance million level QPS, Enough to meet the interface performance test QPS, at present FunTester The design goal is to meet the single process 50 ten thousand QPS. The usage habits are consistent with the previous queue test results , The smaller the number of queues accumulated QPS The higher the , The more threads QPS Will maintain a limit , Single process QPS It will reduce . I'm not sure whether it's related to my own hardware bottleneck . There will be another wave of tests on the server in the future , After all, the server configuration is my own 8 Times more than .

The test case

The test case follows the previous static pressure test model , Fixed thread mode . Follow the previous test Java&Go Keep consistent . If you are interested, you can have a look at it ：

• Java&Go High performance queue LinkedBlockingQueue Performance testing

• Java&Go High performance queue Disruptor Performance testing

• Java&Go High performance queue channel Performance testing

Delayable objects

Here you need to create a deferrable object , Need to inherit a

java.util.concurrent.Delayed

Interface , The specific implementation is as follows ：

 /**
 *  Log object
 */
 static class FunTesterDelay implements Delayed {

 long timestamp

 String str

 FunTesterDelay() {
 this.timestamp = 5
 this.str = DEFAULT_STRING
 }

 @Override
 long getDelay(@NotNull TimeUnit unit) {
 return timestamp - Time.getTimeStamp()
 }

 @Override
 int compareTo(@NotNull Delayed o) {
 return 0
 }
 }


The test case

Use static model threading mode .


 static int thread = 20

 static int times = 100000

 static def delays = new DelayQueue<FunTesterDelay>()

 public static void main(String[] args) {
 RUNUP_TIME = 0
 new Concurrent(new FunTester(),thread,&quot;DelayQueue Performance testing &quot;).start()

 }

 private static class FunTester extends FixedThread {


 FunTester() {
 super(null, times, true)
 }

 @Override
 protected void doing() throws Exception {
 delays.add(new FunTesterDelay())
 }

 @Override
 FunTester clone() {
 return new FunTester()
 }
 }


test result

add to

Here is a simple test of the add function , Method

com.funtest.groovytest.Update.FunTesterDelay#compareTo

By default 0, Just don't sort .

Add delete

Here you can add it first and then delete it , Simple and crude , Look at the results quickly . there 1 individual QPS, Actual equivalent 2 individual QPS.

It seems to be similar to the conclusion of the queue tested before . Keep the queue not too long , Increasing the number of threads will lead to low single thread efficiency , But it's always QPS Still in 250 ten thousand  ~ 300 Between ten thousand . Enough to meet the needs of performance testing .

FunTester Collection of original topics

• Performance test topics

• Java、Groovy、Go、Python

• Single measurement & White box

• FunTester Community style

• Test theory chicken soup

• Special topic of interface function test

• FunTester Video topics

• Case sharing ： programme 、BUG、 Reptiles

• UI Automation topics

• Test tools topic

Read the original , Jump to my warehouse address