master
wangning 7 years ago
parent 9d9b5d2527
commit 9c567a6e98

@ -1,11 +1,5 @@
package au.com.royalpay.payment.manage.apps.core.impls; package au.com.royalpay.payment.manage.apps.core.impls;
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
import javax.annotation.Resource; import javax.annotation.Resource;
import org.junit.Test; import org.junit.Test;
@ -15,14 +9,10 @@ import org.springframework.data.redis.core.BoundListOperations;
import org.springframework.data.redis.core.StringRedisTemplate; import org.springframework.data.redis.core.StringRedisTemplate;
import org.springframework.test.context.ActiveProfiles; import org.springframework.test.context.ActiveProfiles;
import org.springframework.test.context.junit4.SpringRunner; import org.springframework.test.context.junit4.SpringRunner;
import org.springframework.util.CollectionUtils;
import com.alibaba.fastjson.JSONObject; import com.alibaba.fastjson.JSONObject;
import au.com.royalpay.payment.manage.apps.core.CustomerImpressionService;
import au.com.royalpay.payment.manage.mappers.payment.OrderMapper; import au.com.royalpay.payment.manage.mappers.payment.OrderMapper;
import au.com.royalpay.payment.manage.mappers.system.ClientMapper;
import au.com.royalpay.payment.manage.mappers.system.CustomerRelationAlipayMapper;
/** /**
* Created by wangning on 05/01/2018. * Created by wangning on 05/01/2018.
@ -42,16 +32,8 @@ public class CustomerImpressionImplTest {
BoundListOperations<String, String> ops = stringRedisTemplate.boundListOps("customer_impression"); BoundListOperations<String, String> ops = stringRedisTemplate.boundListOps("customer_impression");
JSONObject order = orderMapper.find("00009201711300930013961422"); JSONObject order = orderMapper.find("00009201711300930013961422");
for (int i = 0; i < 10000; i++) { for (int i = 0; i < 10000; i++) {
synchronized (lock) { ops.rightPush(order.toJSONString());
ops.rightPush(order.toJSONString());
}
} }
System.out.println("asdsada");
System.out.println("asdsada");
System.out.println("asdsada");
System.out.println("asdsada");
System.out.println("asdsada");
System.out.println("asdsada");
} }
} }
Loading…
Cancel
Save