jentfoo

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>();

jentfoo

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;

jentfoo

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.

jentfoo

@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);

jentfoo

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;

jentfoo

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();

jentfoo

Keybase proof

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: