orbekk

import java.util.concurrent.CountDownLatch;
import java.util.concurrent.Executors;
import java.util.concurrent.ExecutorService;
import java.util.Iterator;
import java.util.List;
import java.util.ArrayList;

public class Par {
    int parallelism = Runtime.getRuntime().availableProcessors() + 1;
    ExecutorService executor = Executors.newCachedThreadPool();

orbekk

class WithCallback {
  Callback callback = null;

  void done() {
    callback.run();
  }

  protected abstract void run();
}

orbekk

Write a script pardo.sh. It should take a target number of processes N, and a list of commands. The commands should be executed in parallel on up to N processes.

Usage: pardo.sh NUM_PROCESSES COMMAND...

Test as follows:

  time /tmp/pardo.sh 2 "sleep 2" "sleep 4" "sleep 4" "sleep 2"

This should take 6 seconds.

orbekk

#!/bin/bash

if [[ -z $1 ]]; then
  echo "Usage: $(basename $0) NUM_PROCESSES COMMAND..."
fi

NUM_PROCESSES=$1
shift

SEMAPHORE=/tmp/semaphore.$RANDOM

orbekk

#!/bin/bash

function my_print() {
    for arg in "$@"; do
        echo -n "{$arg} "
    done
    echo
}

var1="Two bits"

orbekk

s = r"print \"s = r\\\"\" + s + \"\\\"\"\nprint s.decode(\"string-escape\")"     
print "s = r\"" + s + "\""                                                       
print s.decode("string-escape") 

orbekk

template <class T>
struct Maybe {
 public:
  Maybe() {}
  explicit Maybe(T v) : state_(v) {}

  bool isJust() {
    return state_;
  }

orbekk

#!/bin/bash
#                                                                                
# This script syncs authorized keys (found in the $authorized_keys_file below)   
# to a list of remote hosts. It does not touch existing keys unless overwrite    
# is set to true, but creates a special section containing the keys.  

declare -r begin_marker="### BEGIN MANAGED_BY_KJ_SYNC_AUTHORIZED_KEYS.SH ###"
declare -r end_marker="### END MANAGED_BY_KJ_SYNC_AUTHORIZED_KEYS.SH ###"
declare -r overwrite=true
declare -r tmpdir=$(mktemp -d /tmp/kj_sync_authorized_keys.XXXXX)