Skip to content

Instantly share code, notes, and snippets.

View maxant's full-sized avatar

Ant Kutschera maxant

18 followers · 4 following
View GitHub Profile
@maxant
maxant / Client.java
Last active August 29, 2015 14:12
//type 1
Future<String> f = service.foo(s);
String s = f.get(); //blocks the thread, but at least others can run
//... do something useful with the string...
//type 2
Future<String> f = service.foo(s);
while(!f.isDone()){
try {
Thread.sleep(100);
@maxant
maxant / Service2.java
Last active August 29, 2015 14:12
@Stateless
public class Service2 {
@Asynchronous
public Future<String> foo(String s) {
// simulate some long running process
Thread.sleep(5000);
s += "<br>Service2: threadId=" + Thread.currentThread().getId();
return new AsyncResult<String>(s);
@maxant
maxant / Service4.java
Last active August 29, 2015 14:12
@Stateless
public class Service4 {
@Asynchronous
public void foo(Callback<String> c) {
// simulate some long running process
Thread.sleep(5000);
c.apply("bar");
}
@maxant
maxant / AsyncServlet3.java
Last active August 29, 2015 14:12
@WebServlet(urlPatterns = { "/AsyncServlet3" }, asyncSupported = true)
public class AsyncServlet3 extends HttpServlet {
@EJB private Service4 service;
protected void doGet(HttpServletRequest request, final HttpServletResponse response) throws ServletException, IOException {
...
final AsyncContext ctx = request.startAsync(request, response);
service.foo(s -> {
@maxant
maxant / Service3.java
Last active August 29, 2015 14:12
@Stateless
public class Service3 {
@Asynchronous
public void foo(CompletableFuture<String> cf) {
// simulate some long running process
Thread.sleep(5000);
cf.complete("bar");
}
@maxant
maxant / AsyncServlet2.java
Last active August 29, 2015 14:12
@WebServlet(urlPatterns = { "/AsyncServlet2" }, asyncSupported = true)
public class AsyncServlet2 extends HttpServlet {
@EJB private Service3 service;
protected void doGet(HttpServletRequest request, final HttpServletResponse response) throws ServletException, IOException {
final PrintWriter pw = response.getWriter();
pw.write("<html><body>Started publishing with thread " + Thread.currentThread().getId() + "<br>");
response.flushBuffer(); // send back to the browser NOW
@maxant
maxant / Service2.java
Created January 1, 2015 12:48
package ch.maxant.async;
import java.util.concurrent.Future;
import javax.annotation.Resource;
import javax.ejb.AsyncResult;
import javax.ejb.Asynchronous;
import javax.ejb.Stateless;
import javax.ejb.TransactionAttribute;
import javax.ejb.TransactionAttributeType;
@maxant
maxant / Service1.java
Created January 1, 2015 12:45
package ch.maxant.async;
import java.util.concurrent.Future;
import javax.annotation.Resource;
import javax.ejb.EJB;
import javax.ejb.Stateless;
import javax.ejb.TransactionAttribute;
import javax.ejb.TransactionAttributeType;
import javax.ejb.TransactionManagement;
@maxant
maxant / AsyncServlet.java
Last active August 29, 2015 14:12
package ch.maxant.async;
import java.io.IOException;
import java.io.PrintWriter;
import java.util.concurrent.Future;
import javax.ejb.EJB;
import javax.servlet.ServletException;
import javax.servlet.annotation.WebServlet;
import javax.servlet.http.HttpServlet;
@maxant
maxant / trading-engine-persistSales.js
Created December 30, 2014 21:04
Modifications to the node.jsj trading engine
function persistSales(sales, callback){
if(sales.length === 0 || process.env.skipPersistence) {
callback(); //nothing to do, so continue immediately
}else{
resources.dbConnection(function(err, connection) {
if(err) callback(err); else {
logger.info('preparing to persist ' + sales.length + ' sales');
var count = sales.length;
_.each(sales, function(sale){ //save them in parallel
connection.query(