| <!DOCTYPE html> | |
| <html lang="en"> | |
| <head> | |
| <meta charset="utf-8"> | |
| <meta http-equiv="X-UA-Compatible" content="IE=edge"> | |
| <meta name="viewport" content="width=device-width, initial-scale=1"> | |
| <title>Bootstrap 101 Template</title> | |
| <!-- Bootstrap --> | |
| <!-- Latest compiled and minified CSS --> |
| public class Spawner { | |
| public static void main(String[] args) { | |
| Thread t = new Thread(new Runnable() { | |
| public void run() { | |
| while (true) { | |
| System.out.println("I'm still alive"); | |
| } | |
| } | |
| }); | |
| t.start(); |
| (function(){ | |
| var sequence = Promise.resolve(); | |
| for(var i = 0; i < 10 ; i++){ | |
| const timeout = Math.random() * 1000; | |
| sequence = sequence.then((function(icopy){ | |
| return new Promise((resolve, reject) => {setTimeout(() => { console.log(icopy); resolve();}, timeout);}); | |
| })(i)); | |
| } | |
| })() |
| async function getResponseSize(url) { | |
| const response = await fetch(url); | |
| const reader = response.body.getReader(); | |
| let result = await reader.read(); | |
| let total = 0; | |
| while (!result.done) { | |
| const value = result.value; | |
| total += value.length; | |
| console.log('Received chunk', value); |
| curl -G https://api.github.com/search/repositories --data-urlencode "sort=stars" --data-urlencode "order=desc" --data-urlencode "q=language:java" --data-urlencode "q=created:>`date -v-7d '+%Y-%m-%d'`" | jq ".items[0,1,2] | {name, description, language, watchers_count, html_url}" |
| import java.util.concurrent.BlockingQueue; | |
| import java.util.concurrent.CompletableFuture; | |
| import java.util.concurrent.LinkedBlockingQueue; | |
| import java.util.concurrent.TimeUnit; | |
| public class CommonPoolCompletionService<V> { | |
| private final BlockingQueue<V> completionQueue; | |
| private final BlockingQueue<CompletableFuture<V>> completionQueue1; |
| package com.dealer.modules.cms.promotions.services; | |
| import org.apache.commons.logging.Log; | |
| import org.apache.commons.logging.LogFactory; | |
| import java.util.List; | |
| import java.util.concurrent.RecursiveAction; | |
| import java.util.function.BiFunction; | |
| /*** | |
| * A recursive resultless ForkJoinTask. The BiFunction knows how to take a list of feed and context to generate a ordered results. |
| Stream<Foo> stream = stream1.collect(concat(stream2)).collect(concat(element)); | |
| Stream<Foo> stream = stream1 | |
| .filter(x -> x!=0) | |
| .collect(concat(stream2)) | |
| .filter(x -> x!=1) | |
| .collect(concat(element)) | |
| .filter(x -> x!=2); | |
Want to know the behavoir of your app if a Hystrix Circuit is open?
Run your spring cloud app with -Dhystrix.command.<circuitKeyName>.circuitBreaker.forceOpen=true
<circuiktKeyName> is the name of you hystrix circuit. If you used @HystrixCommand it is the name of the method. If you used @HystrixCommand(commandKey="mykey") is is the value of the commandKey attribute.
| package com.dealer.modules.cms.promotions.services; | |
| import org.apache.commons.logging.Log; | |
| import org.apache.commons.logging.LogFactory; | |
| import java.util.Arrays; | |
| import java.util.List; | |
| import java.util.concurrent.RecursiveAction; | |
| import java.util.function.BiFunction; | |
| /*** |