I hereby claim:
- I am jentfoo on github.
- I am jent (https://keybase.io/jent) on keybase.
- I have a public key ASCXF5qQHh2ufnmYue-DjIMK3kSK2nGxCjzWjf05h-tQWwo
To claim this, I am signing this object:
I hereby claim:
To claim this, I am signing this object:
import org.threadly.util.Clock; | |
import com.google.common.base.Ticker; | |
/** | |
* Adapter between guava's {@link Ticker} and threadly's {@link Clock}. | |
*/ | |
public class ThreadlyTicker extends Ticker { | |
public static final ThreadlyTicker INSTANCE = new ThreadlyTicker(); |
package com.fullcontact.load.sandbox; | |
import java.io.IOException; | |
import java.util.concurrent.Executor; | |
import javax.servlet.AsyncContext; | |
import javax.servlet.Filter; | |
import javax.servlet.FilterChain; | |
import javax.servlet.FilterConfig; | |
import javax.servlet.ServletException; |
@Test | |
public void scheduleLaterThenSoonerTest() { | |
// This test is focused around the scheduling defect fixed in 4.4.1 | |
// The condition hit was where we would park for one scheduled task, then a future task | |
// would not get executed in time because the first parked thread was not woken up | |
final PriorityScheduler scheduler = new PriorityScheduler(2); | |
try { | |
// schedule one task a ways out | |
scheduler.schedule(DoNothingRunnable.instance(), 1000 * 60 * 10); |
diff --git a/aws-java-sdk-sqs/src/main/java/com/amazonaws/services/sqs/MessageMD5ChecksumHandler.java b/aws-java-sdk-sqs/src/main/java/com/amazonaws/services/sqs/MessageMD5ChecksumHandler.java | |
index 3d02445..8d84a39 100644 | |
--- a/aws-java-sdk-sqs/src/main/java/com/amazonaws/services/sqs/MessageMD5ChecksumHandler.java | |
+++ b/aws-java-sdk-sqs/src/main/java/com/amazonaws/services/sqs/MessageMD5ChecksumHandler.java | |
@@ -278,12 +278,10 @@ public class MessageMD5ChecksumHandler extends AbstractRequestHandler { | |
* input ByteBuffer and all the bytes it contains. | |
*/ | |
private static void updateLengthAndBytes(MessageDigest digest, ByteBuffer binaryValue) { | |
- // Rewind the ByteBuffer, in case that get/put operations were applied to | |
- // the unmarshalled BB before it's passed to this handler. |
package crab.db; | |
import java.util.Iterator; | |
import java.util.List; | |
import org.junit.Before; | |
import org.junit.Test; | |
import com.amazonaws.services.dynamodbv2.document.DynamoDB; | |
import com.amazonaws.services.dynamodbv2.document.Item; |
import java.util.HashMap; | |
import java.util.Map; | |
import java.util.concurrent.TimeUnit; | |
import java.util.concurrent.locks.Condition; | |
import java.util.concurrent.locks.Lock; | |
import com.hazelcast.core.ILock; | |
public class ILockWrapper implements Lock { | |
private static final Map<String, Object> LOCK_THREAD_LOCKS = new HashMap<String, Object>(); |