Author: jbellis Date: Fri Jan 28 18:25:13 2011 New Revision: 1064808 URL: http://svn.apache.org/viewvc?rev=1064808&view=rev Log: replace ExecutorService.submit with .execute where a Future is not required patch by jbellis
Modified: cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/db/HintedHandOffManager.java cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/db/Memtable.java Modified: cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/db/HintedHandOffManager.java URL: http://svn.apache.org/viewvc/cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/db/HintedHandOffManager.java?rev=1064808&r1=1064807&r2=1064808&view=diff ============================================================================== --- cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/db/HintedHandOffManager.java (original) +++ cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/db/HintedHandOffManager.java Fri Jan 28 18:25:13 2011 @@ -298,7 +298,7 @@ public class HintedHandOffManager deliverHintsToEndpoint(to); } }; - executor_.submit(r); + executor_.execute(r); } public void deliverHints(String to) throws UnknownHostException Modified: cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/db/Memtable.java URL: http://svn.apache.org/viewvc/cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/db/Memtable.java?rev=1064808&r1=1064807&r2=1064808&view=diff ============================================================================== --- cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/db/Memtable.java (original) +++ cassandra/branches/cassandra-0.7/src/java/org/apache/cassandra/db/Memtable.java Fri Jan 28 18:25:13 2011 @@ -167,7 +167,7 @@ public class Memtable implements Compara public void flushAndSignal(final CountDownLatch latch, ExecutorService sorter, final ExecutorService writer) { cfs.getMemtablesPendingFlush().add(this); // it's ok for the MT to briefly be both active and pendingFlush - writer.submit(new WrappedRunnable() + writer.execute(new WrappedRunnable() { public void runMayThrow() throws IOException {