X-Git-Url: https://code.wpia.club/?a=blobdiff_plain;f=src%2Forg%2Fcacert%2Fgigi%2FdbObjects%2FJob.java;h=a48e44ac667cf5d9ec78d0083568e970c6d7d637;hb=6d1b746247f6e1eab7d1da17112beb9cf5abb089;hp=bb357a8d07b742fddda040031abf4a8ca0dd8d83;hpb=a0232b6e40e7e09767f0444d24e18bf12dafc362;p=gigi.git diff --git a/src/org/cacert/gigi/dbObjects/Job.java b/src/org/cacert/gigi/dbObjects/Job.java index bb357a8d..a48e44ac 100644 --- a/src/org/cacert/gigi/dbObjects/Job.java +++ b/src/org/cacert/gigi/dbObjects/Job.java @@ -51,7 +51,7 @@ public class Job implements IdCachable { } } - public synchronized boolean waitFor(int max) throws InterruptedException { + public synchronized boolean waitFor(int max) { long start = System.currentTimeMillis(); try (GigiPreparedStatement ps = new GigiPreparedStatement("SELECT 1 FROM `jobs` WHERE id=? AND state='open'")) { ps.setInt(1, id); @@ -61,7 +61,12 @@ public class Job implements IdCachable { if (max != 0 && System.currentTimeMillis() - start > max) { return false; } - Thread.sleep((long) (2000 + Math.random() * 2000)); + try { + this.wait((long) (2000 + Math.random() * 2000)); + } catch (InterruptedException ie) { + // Ignore the interruption + ie.printStackTrace(); + } rs = ps.executeQuery(); } }