nkcoder

import ch.qos.logback.classic.Level;
import ch.qos.logback.classic.LoggerContext;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.util.List;

/**
 * change log level at runtime
 * Created by nkcoder on 10/8/16.

nkcoder

package org.nkcoder.module.javatest.concurrent;

import java.time.Duration;
import java.time.Instant;
import java.util.Random;
import java.util.concurrent.CountDownLatch;

/**
 * created by daniel at 12/15/16 21:45
 */

nkcoder

package org.nkcoder.module.javatest.concurrent;

import java.util.concurrent.Semaphore;
import java.util.concurrent.TimeUnit;

/**
 * created by daniel at 12/16/16 08:33
 */
public class SemaphoreTest {

nkcoder

package org.nkcoder.module.javatest.concurrent;

import java.util.concurrent.*;

/**
 * Created by nkcoder on 12/21/16.
 */
public class CompletionServiceTest {

    public static void main(String[] args) {

nkcoder

package org.nkcoder.module.javatest.concurrent;

import java.util.concurrent.CompletableFuture;

/**
 * {@link: http://www.deadcoderising.com/java8-writing-asynchronous-code-with-completablefuture/}
 * Created by nkcoder on 12/21/16.
 */
public class CompletableFutureTest {

nkcoder

package org.nkcoder.module.javatest.concurrent;

import java.util.concurrent.*;
import java.util.concurrent.atomic.AtomicLong;
import java.util.logging.Logger;

/**
 * created by daniel at 2/5/17 22:54
 */
public class TimingThreadPool extends ThreadPoolExecutor {

nkcoder

package org.nkcoder.module.javatest.concurrent;

import java.util.concurrent.*;
import java.util.concurrent.atomic.AtomicLong;
import java.util.logging.Logger;

/**
 * created by daniel at 2/5/17 22:54
 */
public class TimingThreadPool extends ThreadPoolExecutor {