java.util.concurrent.atomic.AtomicBoolean



API Populatity

200 Client projects

Project: java

Package: java.util

Project apache/cassandra in file ...apache.cassandra.streaming.StreamTransferTask.java (2014-08-22)
@@ -21,9 +21,7 @@ import java.util.*;
 import java.util.concurrent.*;
 import java.util.concurrent.ScheduledFuture;
 import java.util.concurrent.atomic.AtomicInteger;
-import java.util.concurrent.atomic.AtomicBoolean;
 
-import io.netty.util.concurrent.*;
 import org.apache.cassandra.concurrent.NamedThreadFactory;
 import org.apache.cassandra.io.sstable.SSTableReader;
 import org.apache.cassandra.streaming.messages.OutgoingFileMessage;
Project netty/netty in file ...va.io.netty.channel.SingleThreadEventLoopTest.java (2013-01-10)
@@ -25,7 +25,6 @@ import java.util.concurrent.Executors;
 import java.util.concurrent.LinkedBlockingQueue;
 import java.util.concurrent.ScheduledFuture;
 import java.util.concurrent.TimeUnit;
-import java.util.concurrent.atomic.AtomicBoolean;
 import java.util.concurrent.atomic.AtomicInteger;
 import java.util.concurrent.atomic.AtomicLong;
 
@@ -62,7 +61,6 @@ public class SingleThreadEventLoopTest {
 
     @Test
     public void shutdownAfterStart() throws Exception {
-        final AtomicBoolean interrupted = new AtomicBoolean();
         final CountDownLatch latch = new CountDownLatch(1);
         loop.execute(new Runnable() {
             @Override
Project wildfly/wildfly in file ...n.subsystem.EmbeddedCacheManagerConfiguration.java (2011-12-16)
@@ -27,7 +27,6 @@ import javax.transaction.TransactionSynchronizationRegistry;
 import java.util.Map;
 import java.util.concurrent.Executor;
 import java.util.concurrent.ScheduledExecutorService;
-import java.util.concurrent.atomic.AtomicBoolean;
 
 import org.infinispan.config.Configuration;
 import org.jboss.msc.value.Value;
@@ -51,5 +50,4 @@ public interface EmbeddedCacheManagerConfiguration {
     Executor getListenerExecutor();
     ScheduledExecutorService getEvictionExecutor();
     ScheduledExecutorService getReplicationQueueExecutor();
-    AtomicBoolean getTransportRequired();
 }