iaveryanov

private boolean decTillZero(AtomicLong counter) {
    while (true) {
        long current = counter.get();
        if (current == 0) {
            return false;
        }
        long next = current - 1;
        if (counter.compareAndSet(current, next)) {
            return true;
        }

iaveryanov

    /**
     * Atomically adds the given value to the current value.
     *
     * @param delta the value to add
     * @return the previous value
     */
    public final long getAndAdd(long delta) {
        while (true) {
            long current = get();
            long next = current + delta;

iaveryanov

package ru.inlinetelecom.vn2.util;

import java.util.concurrent.CountDownLatch;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.concurrent.atomic.AtomicLong;

/**
 * вариант с uncontended lock (getAvailableProcessors >= worker_count

iaveryanov

package ru.inlinetelecom.vn2.util;

import java.util.concurrent.CountDownLatch;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.atomic.AtomicInteger;
import java.util.concurrent.atomic.AtomicLong;

/**
 * вариант с uncontended lock (getAvailableProcessors >= worker_count

iaveryanov

package ru;

public interface InterfaceJava8 {

    public static void main(String[] args) {
        System.out.println("Hello from interface! It is java 8!");
    }
}

iaveryanov

package lambda.puzzle;

// source: http://arhipov.blogspot.ru/2014/02/java-8-lambdas-unintentional-puzzle.html
public class Forrest {
    public Runnable wrooom(){
        return () -> { System.out.println("Hello, lambda!"); };
    }

    public static void main(String[] args) {
        Runnable runnable = new Forrest().wrooom();

iaveryanov

package ru;

// origin source: http://arhipov.blogspot.ru/2014/02/java-8-lambdas-unintentional-puzzle.html
// my gist with puzzle https://gist.github.com/iaveryanov/10990181
public class Forrest {
    public Runnable wrooom(){
        return new Runnable() {
            @Override
            public void run() {
                System.out.println("Hello, lambda!");

iaveryanov

package ru.int_overflow;

public class IntOverflowPuzzle {

    // todo почему при использовании long разница в 1000 раз, действительно на столько медленнее
    // todo почему при переполнении разница во времени в 1000 раз
    private static void doOperation() {
        // change type to long
        //
        // results:

iaveryanov

package ru.int_overflow;

import org.openjdk.jmh.annotations.*;
import org.openjdk.jmh.runner.Runner;
import org.openjdk.jmh.runner.RunnerException;
import org.openjdk.jmh.runner.options.Options;
import org.openjdk.jmh.runner.options.OptionsBuilder;

import java.util.concurrent.TimeUnit;

iaveryanov

public final class Utils {

	private Utils() {
	}
	
	public static void echo(String msg) {
		System.out.println(msg);
	}

	public static void sleep(int millis) {