Examples of java.util.concurrent.locks.ReadWriteLock.writeLock()

Class java.util.concurrent.locks.ReadWriteLock

Examples of java.util.concurrent.locks.ReadWriteLock.writeLock()

java.util.concurrent.locks.ReadWriteLock.writeLock()
Returns the lock used for writing. @return the lock used for writing

  public HostImpl(@Assisted HostEntity hostEntity,
      @Assisted boolean persisted, Injector injector) {
    this.stateMachine = stateMachineFactory.make(this);
    ReadWriteLock rwLock = new ReentrantReadWriteLock();
    this.readLock = rwLock.readLock();
    this.writeLock = rwLock.writeLock();


    this.hostEntity = hostEntity;
    this.injector = injector;
    this.persisted = persisted;
    this.hostDAO = injector.getInstance(HostDAO.class);

View Full Code Here

      this.stateMachine = daemonStateMachineFactory.make(this);
    }


    ReadWriteLock rwLock = new ReentrantReadWriteLock();
    this.readLock = rwLock.readLock();
    this.writeLock = rwLock.writeLock();
    this.serviceComponent = serviceComponent;


    stateEntity = new HostComponentStateEntity();
    stateEntity.setClusterId(serviceComponent.getClusterId());
    stateEntity.setComponentName(serviceComponent.getName());

View Full Code Here

                                  @Assisted HostComponentDesiredStateEntity desiredStateEntity,
                                  Injector injector) {
    injector.injectMembers(this);
    ReadWriteLock rwLock = new ReentrantReadWriteLock();
    this.readLock = rwLock.readLock();
    this.writeLock = rwLock.writeLock();
    this.serviceComponent = serviceComponent;




    this.desiredStateEntity = desiredStateEntity;
    this.stateEntity = stateEntity;

View Full Code Here

    this.sm = context.getStorageManager();
    cursor = new ExecutionBlockCursor(plan);


    ReadWriteLock readWriteLock = new ReentrantReadWriteLock();
    this.readLock = readWriteLock.readLock();
    this.writeLock = readWriteLock.writeLock();


    stateMachine = stateMachineFactory.make(this);
  }


  public float getProgress() {

View Full Code Here

    this.sm = sm;
    this.eventHandler = context.getEventHandler();


    ReadWriteLock readWriteLock = new ReentrantReadWriteLock();
    this.readLock = readWriteLock.readLock();
    this.writeLock = readWriteLock.writeLock();
    stateMachine = stateMachineFactory.make(this);
  }


  public static boolean isRunningState(SubQueryState state) {
    return state == SubQueryState.INITED || state == SubQueryState.NEW || state == SubQueryState.RUNNING;

View Full Code Here

    this.queryUnit = queryUnit;
    this.eventHandler = eventHandler;


    ReadWriteLock readWriteLock = new ReentrantReadWriteLock();
    this.readLock = readWriteLock.readLock();
    this.writeLock = readWriteLock.writeLock();


    stateMachine = stateMachineFactory.make(this);
  }


  public TaskAttemptState getState() {

View Full Code Here

    nextAttempt = -1;
    failedAttempts = 0;


    ReadWriteLock readWriteLock = new ReentrantReadWriteLock();
    this.readLock = readWriteLock.readLock();
    this.writeLock = readWriteLock.writeLock();
    this.scheduleContext = scheduleContext;


    stateMachine = stateMachineFactory.make(this);
    totalFragmentNum = 0;
  }

View Full Code Here

    data.read();
    QueueLock qlock = new MockQueueLock();
    
    final ReadWriteLock locker = new DistributedReadWriteLock(qlock, "locker1".getBytes());
    Lock readLock = locker.readLock();
    Lock writeLock = locker.writeLock();
    readLock.lock();
    readLock.unlock();
    writeLock.lock();
    writeLock.unlock();
    readLock.lock();

View Full Code Here

    for (int i = 0; i < threads.length; i++) {
      final int which = i;
      threads[i] = new Thread() {
        public void run() {
          if (which % 2 == 0) {
            Lock wl = locker.writeLock();
            wl.lock();
            try {
              data.write();
            } finally {
              wl.unlock();

View Full Code Here

  public DirectUpdateHandler2(SolrCore core) throws IOException {
    super(core);


    ReadWriteLock rwl = new ReentrantReadWriteLock();
    iwAccess = rwl.readLock();
    iwCommit = rwl.writeLock();


    tracker = new CommitTracker();
  }


  // must only be called when iwCommit lock held

View Full Code Here

0 1 2 3 4 5 6 7 8 9

TOP

All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.