TestListener( int expCount, int id ) {
name = "TestListener " + id;
- actual = Collections.synchronizedList( Lists.<N>newArrayListWithCapacity( expCount ) );
+ actual = Collections.synchronizedList( Lists.newArrayListWithCapacity( expCount ) );
reset( expCount );
}
queueExecutor = Executors.newFixedThreadPool( 2 );
NotificationManager<TestListener<Integer>, Integer> manager =
- new QueuedNotificationManager<>( queueExecutor, new TestNotifier<Integer>(),
+ new QueuedNotificationManager<>( queueExecutor, new TestNotifier<>(),
10, "TestMgr" );
int initialCount = 6;
manager.submitNotifications( listener, Arrays.asList( 4, 5 ) );
manager.submitNotification( listener, 6 );
- manager.submitNotifications( null, Collections.<Integer>emptyList() );
+ manager.submitNotifications( null, Collections.emptyList() );
manager.submitNotifications( listener, null );
manager.submitNotification( listener, null );
queueExecutor = Executors.newFixedThreadPool( nListeners );
final ExecutorService stagingExecutor = Executors.newFixedThreadPool( nListeners );
final NotificationManager<TestListener<Integer>, Integer> manager =
- new QueuedNotificationManager<>( queueExecutor, new TestNotifier<Integer>(),
+ new QueuedNotificationManager<>( queueExecutor, new TestNotifier<>(),
5000, "TestMgr" );
final int nNotifications = 100000;
List<TestListener<Integer>> listeners = Lists.newArrayList();
for( int i = 1; i <= nListeners; i++ ) {
final TestListener<Integer> listener =
- i == 2 ? new TestListener2<Integer>( nNotifications, i ) :
- i == 3 ? new TestListener3<Integer>( nNotifications, i ) :
- new TestListener<Integer>( nNotifications, i );
+ i == 2 ? new TestListener2<>(nNotifications, i) :
+ i == 3 ? new TestListener3<>(nNotifications, i) :
+ new TestListener<>(nNotifications, i);
listeners.add( listener );
new Thread( new Runnable() {
queueExecutor = Executors.newFixedThreadPool( 1 );
NotificationManager<TestListener<Integer>, Integer> manager =
- new QueuedNotificationManager<>( queueExecutor, new TestNotifier<Integer>(),
+ new QueuedNotificationManager<>( queueExecutor, new TestNotifier<>(),
10, "TestMgr" );
final CountDownLatch errorCaughtLatch = new CountDownLatch( 1 );
queueExecutor = new ThreadPoolExecutor( 1, 1, 0, TimeUnit.SECONDS,
- new LinkedBlockingQueue<Runnable>() ) {
+ new LinkedBlockingQueue<>() ) {
@Override
public void execute( final Runnable command ) {
super.execute( new Runnable() {
};
NotificationManager<TestListener<Integer>, Integer> manager =
- new QueuedNotificationManager<>( queueExecutor, new TestNotifier<Integer>(),
+ new QueuedNotificationManager<>( queueExecutor, new TestNotifier<>(),
10, "TestMgr" );
TestListener<Integer> listener = new TestListener<>( 2, 1 );