Codewut Because Software Matters

public class TestThreadPool extends TestCase
{
 private static Log log = LogFactory.getLog(TestThreadPool.class);
 
 public void testLoadTracker() throws InterruptedException
 {
  int maxRunningThreads = 128;
  int maxLoad = 500;
 
  LoadTracker load = new LoadTracker(maxLoad);
  ExecutorService pool = Executors.newFixedThreadPool(maxRunningThreads);
 
  for (int i = 0; i < 500; i++)
  {
   // here you would create your real job and *predict* its impact on the load factor.
   // we choose the load to be random.
   int predictedJobLoad = (int) Math.round(Math.random() * 10l);
   MyJob aJob = new MyJob(load, predictedJobLoad,"job-"+i,this);
 
   while (!load.canHandle(predictedJobLoad))
   {
    log.debug(String.format("WAIT: current load %d and new job is about to be %d", load.get(), predictedJobLoad));
    synchronized (this) { this.wait(1000); }
   }
 
   log.debug(String.format("QUEUE: current load is %d and new job is about to be %d", load.get(), predictedJobLoad));
   pool.execute(aJob);
  }
  pool.shutdown();
  pool.awaitTermination(42,TimeUnit.DAYS);
  assertEquals(0, load.get());
 }
 
 private  class MyJob implements Runnable
 {
  private LoadTracker loadTracker;
  private int load;
  private String jobId;
  private Object monitor;
 
  public MyJob(LoadTracker loadTracker, int load, String jobId, Object monitor)
  {
   this.jobId = jobId;
   this.loadTracker = loadTracker;
   this.load = load;
   this.monitor = monitor;
   loadTracker.add(load);
  }
 
  @Override
  public void run()
  {
   log.debug(String.format("RUN: %s with a load of %d", jobId, load));
   try
   {
    Thread.sleep((int) Math.round(Math.random() * 5000l));
   }
   catch (InterruptedException e)
   {
    e.printStackTrace();
   }
   log.debug(String.format("FIN: %s with a load of %d", jobId, load));
   loadTracker.remove(load);
   if (monitor != null) synchronized (monitor) { monitor.notify(); }
  }
 }
 
 private class LoadTracker
 {
  private int currentLoad = 0;
  private int maxLoad = 0;
 
  public LoadTracker(int maxLoad)
  {
   this.maxLoad = maxLoad;
  }
 
  private synchronized void add(int load)
  {
   this.currentLoad += load;
  }
 
  private synchronized void remove(int load)
  {
   this.currentLoad -= load;
  }
 
  public synchronized int get()
  {
   return currentLoad;
  }
 
  public synchronized boolean canHandle(int additionalLoad)
  {
   return ((this.get() + additionalLoad) < maxLoad);
  }
 }
}

me@host:/mnt/data1/import$ cat bigfile.txt | pv | pigz -c | ssh me@otherhost 'cat | unpigz > /mnt/data1/bigfile.txt'
1.83GB 0:00:18 [95.3MB/s] [                            <=>                                                   ]

// note: there is a bug in Sharepoint 2007 when using ", " within a page name - "foo, bar.aspx" for instance. 
// note: This will render the relationship list entry useless. A healthy object id attribute in a 
// note: relationship list's entry looks like this: 
// note: ows_ObjectID='http://mucskysp04:4711/DE/Seiten/Seite mit Sönderzeichen.aspx, /DE/Seiten/Seite mit Sönderzeichen.aspx' 
// note: once "broken" using the naming-"exploit", the relationship will be represented as:
// note: ows_ObjectID='http://mucskysp04:4711/DE/Seiten/variationsseite, mitkommaundleerzeichen.aspx' 
// note: note the missing relative path. There is no reason to work around this bug in this tool since the original
// note: entry in Sharepoint won't be functional anyway (no entries will be shown in the variations dropdown)

<?xml version="1.0"?>
 
<overlay id="myOverlay"
  xmlns="http://www.mozilla.org/keymaster/gatekeeper/there.is.only.xul"
  xmlns:html="http://www.w3.org/1999/xhtml">
 
  <statusbar id="status-bar">
    <statusbarpanel>
      <box>
        <html:canvas id="myCanvas" width="15" height="15" style="border:1px solid black;"/>
      </box>
    </statusbarpanel>
  </statusbar>
</overlay>

var canvas = window.document.getElementById("myCanvas");
var ctx = canvas.getContext("2d");
ctx.fillStyle = "red";
ctx.fillRect(5,5,5,5);

dojo.provide("myWidgets.Dialog");
 
dojo.declare
(
  "myWidgets.Dialog",
  [dijit.Dialog],
  {
    // summary:
    //    extended version of the dojo Dialog widget with the option to disable
    //    the close button and supress the escape key. 
 
    disableCloseButton: true,
 
    /* *********************************************************** postCreate */
    postCreate: function()
    {
      this.inherited(arguments);
      this._updateCloseButtonState();
    },
 
    /* *************************************************************** _onKey */
    _onKey: function(evt)
    {
      if(this.disableCloseButton && evt.charOrCode == dojo.keys.ESCAPE) return;
      this.inherited(arguments);
    },
 
    /* ************************************************ setCloseButtonDisabled*/
    setCloseButtonDisabled: function(flag)
    {
      this.disableCloseButton = flag;
      this._updateCloseButtonState();
    },
 
    /* ********************************************** _updateCloseButtonState */
    _updateCloseButtonState: function()
    {
      dojo.style(this.closeButtonNode,
      "display",this.disableCloseButton ? "none" : "block");
    }
  }
);

Connection connection = dataSource.getConnection();
Statement st = connection.createStatement(java.sql.ResultSet.TYPE_FORWARD_ONLY, java.sql.ResultSet.CONCUR_READ_ONLY);
st.setFetchSize(Integer.MIN_VALUE); // Inter.MIN_VALUE <- and ONLY this value, 1,5 or 100 won't fix your problem.
ResultSet rs = st.executeQuery("select * from someREALLYHugeTable");

public class MarketMerchant : IHasAdorable<CheeseBurger>, IProductSeller
{
  // defined in IHasAdorable
  CheeseBurger BuyAdorable() 
  { 
    return new AdorableCheeseburger(); 
  }
 
  // defined in IProductSeller
  IProduct Buy(String eanCode) 
  { 
    if (eanCode.equals("12345"))
      return this.bigStackOfSmellyFishburgers.Pop();
    else
      throw new IAmSoSorryException("We don't have any of these!");
  }
}

  IProductSeller merchant;
  // iteration goes here
  if (merchant is IHasAdorable<object>)
  {
    // this wont work. We are selling something very special, not just a stupid object!
    // Casting to IHasAdorable<> won't even compile.    
  }

  typeof(IHasAdorable<object>).IsAssignableFrom(merchant) 

  // `1 means there is 1 Generic parameter 
  Type adorableInterfaceType = merchant.GetType().GetInterface("IHasAdorable`1"); 
 
  if (adorableInterfaceType != null)
  {
    // yay, the merchant has adorable products, what whould those be!?
    Type adorableProductType = adorableInterfaceType.GetGenericArguments()[0];
 
    // here is the magic we need to get the correct IHasAdorable Type 
    // with "filled in" generic type.
    Type genericAdorableInterfaceType = 
      typeof(IHasAdorable<>).MakeGenericType(adorableProductType);
    MethodInfo mi = genericAdorableInterfaceType.GetMethod("BuyAdorable");
    myBagOfAdorableProducts.Add(mi.invoke(merchant,null));    
  }