Examples of edu.emory.mathcs.backport.java.util.concurrent.locks.Lock.unlock()

Package edu.emory.mathcs.backport.java.util.concurrent.locks

Class edu.emory.mathcs.backport.java.util.concurrent.locks.Lock

Examples of edu.emory.mathcs.backport.java.util.concurrent.locks.Lock.unlock()

edu.emory.mathcs.backport.java.util.concurrent.locks.Lock.unlock()
Releases the lock.
Implementation Considerations
A Lock implementation will usually impose restrictions on which thread can release a lock (typically only the holder of the lock can release it) and may throw an (unchecked) exception if the restriction is violated. Any restrictions and the exception type must be documented by that Lock implementation.

            }


            return _constraintInfo;
        } finally
        {
            _lock.unlock();
        }
    }


    public ConstraintInfo[] get_all_constraints()
    {

View Full Code Here

                        return first.obj;
                    }
                }
            }
        } finally {
            lock.unlock();
        }
        return null;
    }


    private Buffer allocateNew(int capacity, boolean direct) {

View Full Code Here

                lock.lock();
                try {
                    value.next = (Entry) createPool(heapPools, index).put(key,
                            value);
                } finally {
                    lock.unlock();
                }
            }
            content = null;
            super._release();
        }

View Full Code Here

                lock.lock();
                try {
                    value.next = (Entry) createPool(directPools, index).put(
                            key, value);
                } finally {
                    lock.unlock();
                }
            }
            content = null;
            super._release();
        }

View Full Code Here

                            }
                        }
                    }
                    done(exchange);
                } finally {
                    lock.unlock();
                }
            }
        // Handle an ACTIVE exchange as a CONSUMER
        } else if (exchange.getStatus() == ExchangeStatus.ACTIVE) {
            done(exchange);

View Full Code Here

                }
            }
        } catch (Exception e) {
            log.info("Caught exception while processing timeout aggregation", e);
        } finally {
            lock.unlock();
        }
    }
    
    /**
     * Check if the aggregation with the given correlation id is closed or not.

View Full Code Here

            }


            this.db.addNodeRequest(req, coschedid);


        } finally {
            lock.unlock();
        }
    }


    /**
     * @param coschedid coschedid

View Full Code Here

        try {
            this.proceedCoscheduleImpl(coschedid);
        } catch (WorkspaceDatabaseException e) {
            throw new SchedulingException(e.getMessage(), e);
        } finally {
            lock.unlock();
        }
    }


    // method is under lock on coschedid
    private void proceedCoscheduleImpl(String coschedid)

View Full Code Here

                throw new CreationException(
                        "ID collision, ID '" + idStr + "' already in cache");
            }


        } finally {
            lock.unlock();
        }


        return resource;
    }

View Full Code Here

            this.cache.remove(id);
            throw e;
        } catch (CreationException e) {
            throw new ManageException(e.getMessage(), e); // ...
        } finally {
            lock.unlock();
        }


        return resource;
    }

View Full Code Here

0 1 2

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.