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
{
