I hereby claim:
- I am marccarre on github.
- I am marccarre (https://keybase.io/marccarre) on keybase.
- I have a public key whose fingerprint is E783 6CDE 2E42 F8FE 3847 0FBF 0626 58EF F69B 8B32
To claim this, I am signing this object:
import scala.util.Random | |
def winningCombinationsFor(max: Int = 49, numDrawn: Int = 6, minNumToWin: Int = 3): Seq[Set[Int]] = { | |
val (draw, remainder) = Random.shuffle(1 to max).splitAt(numDrawn) | |
for { | |
numPickedFromDraw <- minNumToWin to numDrawn | |
subsetFromDraw <- draw.toSet.subsets(numPickedFromDraw) | |
subsetFromRemainder <- remainder.toSet.subsets(numDrawn - numPickedFromDraw) | |
} yield subsetFromDraw ++ subsetFromRemainder | |
} |
import java.util.concurrent.CompletableFuture; | |
import java.util.concurrent.ExecutionException; | |
public class AsynchronousExceptionsHandlingWithExceptionally { | |
public static void main(final String[] args) throws InterruptedException, ExecutionException { | |
for (final boolean failure : new boolean[]{false, true}) { | |
CompletableFuture<Integer> x = CompletableFuture.supplyAsync(() -> { | |
if (failure) { | |
throw new RuntimeException("Oops, something went wrong"); |
import java.util.concurrent.CompletableFuture; | |
import java.util.concurrent.ExecutionException; | |
import static java.lang.String.format; | |
public class AsynchronousExceptionsHandlingWithHandle { | |
public static void main(final String[] args) throws InterruptedException, ExecutionException { | |
for (final boolean failure : new boolean[]{false, true}) { | |
CompletableFuture<Integer> x = CompletableFuture.supplyAsync(() -> { | |
if (failure) { |
import java.util.concurrent.CompletableFuture; | |
import java.util.concurrent.ExecutionException; | |
public class AsynchronousExceptionsHandlingWithWhenComplete { | |
public static void main(final String[] args) throws InterruptedException, ExecutionException { | |
for (final boolean failure : new boolean[]{false, true}) { | |
CompletableFuture<Integer> x = CompletableFuture.supplyAsync(() -> { | |
if (failure) { | |
throw new RuntimeException("Oops, something went wrong"); |
import java.util.concurrent.CompletableFuture; | |
import java.util.concurrent.ExecutionException; | |
import java.util.concurrent.TimeUnit; | |
import static java.util.concurrent.TimeUnit.SECONDS; | |
public class SynchronousVsAsynchronous { | |
public static void main(final String[] args) { | |
stopwatch(() -> { | |
// Synchronous: | |
int x1 = compute(1); |
package com.marccarre; | |
import java.util.Arrays; | |
import java.util.Comparator; | |
import java.util.concurrent.CompletableFuture; | |
import java.util.concurrent.ExecutionException; | |
import java.util.concurrent.TimeUnit; | |
import java.util.stream.Stream; | |
import static java.util.concurrent.CompletableFuture.completedFuture; |
import java.util.concurrent.CompletableFuture; | |
import java.util.concurrent.ConcurrentHashMap; | |
import java.util.concurrent.ConcurrentMap; | |
import java.util.concurrent.ExecutionException; | |
import java.util.concurrent.TimeUnit; | |
import static java.util.concurrent.TimeUnit.SECONDS; | |
public class AsynchronousLongComputeVsSlowStore { | |
private static final ConcurrentMap<Integer, Integer> store = new ConcurrentHashMap<>(); |
I hereby claim:
To claim this, I am signing this object:
import java.util.concurrent.CompletableFuture; | |
import java.util.concurrent.ExecutionException; | |
public class AsynchronousExceptions { | |
public static void main(final String[] args) throws InterruptedException { | |
for (final boolean failure : new boolean[]{false, true}) { | |
CompletableFuture<Integer> x = CompletableFuture.supplyAsync(() -> { | |
if (failure) { | |
throw new RuntimeException("Oops, something went wrong"); |
from __future__ import annotations # To allow "MinHeap.push -> MinHeap:" | |
from typing import Generic, List, Optional, TypeVar | |
from heapq import heapify, heappop, heappush, heapreplace | |
T = TypeVar('T') | |
class MinHeap(Generic[T]): | |
''' |