public synchronized void startRead(int thread, final SessionRead task) {
- session.queryProvider2.schedule(new SessionTask(null) {
+ session.queryProvider2.scheduleNow(new SessionTask(null) {
@Override
public void run0(int thread) {
public synchronized void startReadUpdate(int thread) {
- session.queryProvider2.schedule(new SessionTask(null) {
+ session.queryProvider2.scheduleNow(new SessionTask(null) {
@Override
public void run0(int thread) {
public synchronized void startWrite(int thread, final SessionTask task) {
- session.queryProvider2.schedule(new SessionTask(null) {
+ session.queryProvider2.scheduleNow(new SessionTask(null) {
@Override
public void run0(int thread) {
public synchronized void startWriteUpdate(int thread) {
- session.queryProvider2.schedule(new SessionTask(null) {
+ session.queryProvider2.scheduleNow(new SessionTask(null) {
@Override
public void run0(int thread) {
if (!reads.isEmpty()) {
final SessionRead read = reads.poll();
- session.queryProvider2.schedule(new SessionTask(null) {
+ session.queryProvider2.scheduleNow(new SessionTask(null) {
@Override
public void run0(int thread) {
assert(State.INIT != state);
if(State.READ == state) {
- session.queryProvider2.schedule(new SessionTask(null) {
+ session.queryProvider2.scheduleNow(new SessionTask(null) {
@Override
public void run0(int thread) {