Reduced waiting time for threads after actions
Signed-off-by: Jim Martens <github@2martens.de>
This commit is contained in:
@ -46,7 +46,7 @@ public class ClientThread extends Thread {
|
|||||||
*/
|
*/
|
||||||
private int beginTransaction() throws InterruptedException {
|
private int beginTransaction() throws InterruptedException {
|
||||||
int taid = _manager.beginTransaction();
|
int taid = _manager.beginTransaction();
|
||||||
Thread.sleep(2000);
|
Thread.sleep(200);
|
||||||
return taid;
|
return taid;
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -56,7 +56,7 @@ public class ClientThread extends Thread {
|
|||||||
*/
|
*/
|
||||||
private void commit(int taid) throws InterruptedException {
|
private void commit(int taid) throws InterruptedException {
|
||||||
_manager.commit(taid);
|
_manager.commit(taid);
|
||||||
Thread.sleep(2000);
|
Thread.sleep(200);
|
||||||
}
|
}
|
||||||
|
|
||||||
/**
|
/**
|
||||||
@ -66,6 +66,6 @@ public class ClientThread extends Thread {
|
|||||||
private void write(int taid) throws InterruptedException {
|
private void write(int taid) throws InterruptedException {
|
||||||
int pageID = ThreadLocalRandom.current().nextInt(_lowerPageBound, _upperPageBound + 1);
|
int pageID = ThreadLocalRandom.current().nextInt(_lowerPageBound, _upperPageBound + 1);
|
||||||
_manager.write(taid, pageID, "transaction " + taid + " of client " + _id);
|
_manager.write(taid, pageID, "transaction " + taid + " of client " + _id);
|
||||||
Thread.sleep(2000);
|
Thread.sleep(200);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user