List of writeLock() Examples

Examples of writeLock()

EDU.oswego.cs.dl.util.concurrent.ReadWriteLock.writeLock()
get the writeLock
EDU.oswego.cs.dl.util.concurrent.ReentrantWriterPreferenceReadWriteLock.writeLock()
ca.odell.glazedlists.util.concurrent.ReadWriteLock.writeLock()
Return the lock used for writing.
com.intellij.util.concurrency.JBReentrantReadWriteLock.writeLock()
com.netflix.curator.framework.recipes.locks.InterProcessReadWriteLock.writeLock()
com.sun.corba.se.pept.transport.Connection.writeLock()
Grab a write lock on the Connection. If another thread already has a write lock then the calling thread will block until the lock is released. The calling thread must call {@link #writeUnlock}when it is done.
java.util.concurrent.locks.ReadWriteLock.writeLock()
Returns the lock used for writing. @return the lock used for writing
java.util.concurrent.locks.ReentrantReadWriteLock.writeLock()
jersey.repackaged.jsr166e.StampedLock.writeLock()
Exclusively acquires the lock, blocking if necessary until available. @return a stamp that can be used to unlock or convert mode
lineage2.gameserver.instancemanager.commission.CommissionItemContainer.writeLock()
Method writeLock.
lineage2.gameserver.model.items.PcFreight.writeLock()
Method writeLock.
lineage2.gameserver.model.items.PcInventory.writeLock()
Method writeLock.
lineage2.gameserver.model.items.Warehouse.writeLock()
Method writeLock.
net.sf.hajdbc.lock.LockManager.writeLock()
Obtains a named write lock. @param object an object to lock @return a write lock
org.apache.accumulo.fate.zookeeper.DistributedReadWriteLock.writeLock()
org.apache.accumulo.server.zookeeper.DistributedReadWriteLock.writeLock()
org.apache.clerezza.rdf.core.access.debug.ReentrantReadWriteLockTracker.writeLock()
org.apache.clerezza.rdf.utils.GraphNode.writeLock()
@return
org.apache.curator.framework.recipes.locks.InterProcessReadWriteLock.writeLock()
Returns the lock used for writing. @return write lock
org.apache.hadoop.hbase.InterProcessReadWriteLock.writeLock()
Obtain a writer lock containing given metadata. @param metadata See documentation of metadata parameter in readLock() @return An instantiated InterProcessReadWriteLock instance
org.apache.hadoop.hbase.master.TableLockManager.writeLock()
Returns a TableLock for locking the table for exclusive access @param tableName Table to lock @param purpose Human readable reason for locking the table @return A new TableLock object for acquiring a write lock
org.apache.hadoop.hbase.zookeeper.lock.ZKInterProcessReadWriteLock.writeLock()
{@inheritDoc}
org.apache.hadoop.hdfs.server.namenode.FSNamesystem.writeLock()
org.apache.ojb.odmg.locking.LockManager.writeLock()
aquires a writelock for transaction tx on object obj. Returns true if successful, else false.
org.apache.ojb.otm.lock.isolation.TransactionIsolation.writeLock()
org.apache.openjpa.datacache.QueryCache.writeLock()
Obtain a write lock on the cache.
org.exolab.castor.persist.LockEngine.writeLock()
Acquire a write lock on the object. A write lock assures that the object exists and can be stored/deleted when the transaction commits. It prevents any concurrent updates to the object from this point on. However, it does not guarantee that the object has not been modified in the course of the transaction. For that the object must be loaded with exclusive access. @param tx The transaction context @param oid The object's OID @param timeout The timeout waiting to acquire a lock on theobject (specified in seconds) @throws LockNotGrantedException Timeout or deadlock occuredattempting to acquire lock on object @throws ObjectDeletedException The object has been deleted frompersistent storage @throws PersistenceException An error reported by thepersistence engine
org.geotools.caching.spatialindex.NodeIdentifier.writeLock()
Acquire a write lock on the node
org.gephi.graph.api.Graph.writeLock()
Acquires a write lock on the graph. Calling thread will be blocked until all read locks are released. Several threads can read but only once can write. @see ReentrantReadWriteLock @throws IllegalMonitorStateException if the current thread is holding a read lock
org.impalaframework.module.spi.FrameworkLockHolder.writeLock()
Locks framework for writing. Invoked when module operations are invoked
org.jboss.cache.lock.ReadWriteLockWithUpgrade.writeLock()

Examples of net.sf.hajdbc.lock.LockManager.writeLock()

    {
      LockManager lockManager = cluster.getLockManager();
      
      for (String identifier: identifierSet)
      {
        lockList.add(lockManager.writeLock(identifier));
      }
    }
    
    return lockList;
  }

View Full Code Here

Examples of org.apache.accumulo.fate.zookeeper.DistributedReadWriteLock.writeLock()

    ZooQueueLock qlock = new ZooQueueLock(ZooUtil.getRoot(HdfsZooInstance.getInstance()) + Constants.ZTABLE_LOCKS + "/" + tableId, false);
    Lock lock = DistributedReadWriteLock.recoverLock(qlock, lockData);
    if (lock == null) {
      DistributedReadWriteLock locker = new DistributedReadWriteLock(qlock, lockData);
      if (writeLock)
        lock = locker.writeLock();
      else
        lock = locker.readLock();
    }
    return lock;
  }

View Full Code Here

Examples of org.apache.accumulo.server.zookeeper.DistributedReadWriteLock.writeLock()

    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

Examples of org.apache.clerezza.rdf.core.access.debug.ReentrantReadWriteLockTracker.writeLock()

        printWriter.append("\n");
      }
      if (lock.isWriteLocked() && lock instanceof ReentrantReadWriteLockTracker) {
        ReentrantReadWriteLockTracker debugLock = (ReentrantReadWriteLockTracker) lock;
        printWriter.append("Thread holding write-lock: \n");
        printStackTrace(debugLock.writeLock().getStackTrace(), printWriter);
        printWriter.append("\n");
      }
      printWriter.append("Queue length:       " + lock.getQueueLength());
      printWriter.append("\n");
      printWriter.append("Queued threads: ");

View Full Code Here

Examples of org.apache.clerezza.rdf.utils.GraphNode.writeLock()

      }
      while (oldParentTripleIter.hasNext()) {
        logger.error("more than one parent statement: "+oldParentTripleIter.next());
        oldParentTripleIter.remove();
      }
      Lock writeLock = node.writeLock();
      writeLock.lock();
      try {
        node.replaceWith(targetUri);
      } finally {
        writeLock.unlock();

View Full Code Here

Examples of org.apache.curator.framework.recipes.locks.InterProcessReadWriteLock.writeLock()

            else {
                lockEntry = new InterProcessReadWriteLock(zk.getClient(), LOCKS_NODE + "/" + resource);
                zkLocks.put(resource, lockEntry);
            }
        }
        InterProcessMutex writeLock = lockEntry.writeLock();
        return acquireLock(wait, writeLock, resource);
    }


    private LockToken acquireLock(long wait, InterProcessMutex lock, String resource) {
        ZKLockToken token = null;

View Full Code Here

Examples of org.apache.hadoop.hbase.InterProcessReadWriteLock.writeLock()

          .setCreateTime(EnvironmentEdgeManager.currentTimeMillis()).build();
        byte[] lockMetadata = toBytes(data);


        InterProcessReadWriteLock lock = new ZKInterProcessReadWriteLock(zkWatcher, tableLockZNode,
          METADATA_HANDLER);
        return isShared ? lock.readLock(lockMetadata) : lock.writeLock(lockMetadata);
      }
    }


    private static byte[] toBytes(ZooKeeperProtos.TableLock data) {
      return ProtobufUtil.prependPBMagic(data.toByteArray());

View Full Code Here

Examples of org.apache.hadoop.hbase.master.TableLockManager.writeLock()


    ServerName mockName = ServerName.valueOf("localhost", 60000, 1);


    // obtain one lock
    final TableLockManager tableLockManager = TableLockManager.createTableLockManager(conf, TEST_UTIL.getZooKeeperWatcher(), mockName);
    TableLock writeLock = tableLockManager.writeLock(TableName.valueOf("foo"),
        "testCheckTableLocks");
    writeLock.acquire();
    hbck = doFsck(conf, false);
    assertNoErrors(hbck); // should not have expired, no problems

View Full Code Here

Examples of org.apache.hadoop.hbase.master.TableLockManager.writeLock()


    final CountDownLatch latch = new CountDownLatch(1);
    new Thread() {
      @Override
      public void run() {
        TableLock readLock = tableLockManager.writeLock(TableName.valueOf("foo"),
            "testCheckTableLocks");
        try {
          latch.countDown();
          readLock.acquire();
        } catch (IOException ex) {

View Full Code Here

Examples of org.apache.hadoop.hbase.master.TableLockManager.writeLock()


    hbck = doFsck(conf, false);
    assertNoErrors(hbck);


    // ensure that locks are deleted
    writeLock = tableLockManager.writeLock(TableName.valueOf("foo"),
        "should acquire without blocking");
    writeLock.acquire(); // this should not block.
    writeLock.release(); // release for clean state
  }

View Full Code Here

0 1 2 3 4 5 6 7

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.