Implementations must L169: * be thread-safe. L170: * L171: * @since 13.0 L172: */ L173: public interface Policy { L174: L175: /** L176: * Called when a potential deadlock is encountered. Implementations can throw the given {@code L177: * exception} and/or execute other desired logic. L178: * L179: * <p>Note that the method will be called even upon an invocation of {@code tryLock()}. Although L180: * {@code tryLock()} technically recovers from deadlock by eventually timing out,...

L106: L107: (d) If the Work includes a "NOTICE" text file as part of its L108: distribution, then any Derivative Works that You distribute must L109: include a readable copy of the attribution notices contained L110: within such NOTICE file, excluding those notices that do not L111: pertain to any part of the Derivative Works, in at least one L112: of the following places: within a NOTICE text file distributed L113: as part of the Derivative Works;...

L107: L108: (d) If the Work includes a "NOTICE" text file as part of its L109: distribution, then any Derivative Works that You distribute must L110: include a readable copy of the attribution notices contained L111: within such NOTICE file, excluding those notices that do not L112: pertain to any part of the Derivative Works, in at least one L113: of the following places: within a NOTICE text file distributed L114: as part of the Derivative Works;...

L107: L108: (d) If the Work includes a "NOTICE" text file as part of its L109: distribution, then any Derivative Works that You distribute must L110: include a readable copy of the attribution notices contained L111: within such NOTICE file, excluding those notices that do not L112: pertain to any part of the Derivative Works, in at least one L113: of the following places: within a NOTICE text file distributed L114: as part of the Derivative Works;...

return new ConditionBeanExceptionThrower(); L94: } L95: L96: @Override L97: public void xsetPaging(boolean paging) { L98: // Do nothing because this is unsupported on ConditionBean. L99: // And it is possible that this method is called by PagingInvoker. L100: } L101: L102: @Override L103: public void enablePagingCountLater() { L104: // nothing L105: } L106: L107: @Override L108: public void disablePagingCountLater() { L109: // nothing L110: } L111:...

L131: } L132: L133: @Override L134: Collection<V> createValues() { L135: return new FilteredMultimapValues<>(this); L136: } L137: L138: @Override L139: Iterator<Entry<K, V>> entryIterator() { L140: throw new AssertionError("should never be called"); L141: } L142: L143: @Override L144: Map<K, Collection<V>> createAsMap() { L145: return new AsMap(); L146: } L147: L148: @Override L149: Set<K> createKeySet() { L150: return asMap().keySet(); L151: } L152: L153: boolean removeEntriesIf(Predicate<?...

again, not get the old exception L1903: try { L1904: cache.getUnchecked("bar"); L1905: fail(); L1906: } catch (InvalidCacheLoadException expected) { L1907: } L1908: assertEquals(2, callCount.get()); L1909: } L1910: L1911: /** L1912: * On a concurrent computation that throws an unchecked exception, all threads should get the L1913: * (wrapped) exception, with the loader called only once. The result should not be cached (a later L1914: * request should call the loader again)....

private WorkerRunningState workerRunningState = IDLE; L77: L78: /** L79: * This counter prevents an ABA issue where a thread may successfully schedule the worker, the L80: * worker runs and exhausts the queue, another thread enqueues a task and fails to schedule the L81: * worker, and then the first thread's call to delegate.execute() returns. Without this counter, L82: * it would observe the QUEUING state and set it to QUEUED, and the worker would never be L83: * scheduled again for future...

private WorkerRunningState workerRunningState = IDLE; L77: L78: /** L79: * This counter prevents an ABA issue where a thread may successfully schedule the worker, the L80: * worker runs and exhausts the queue, another thread enqueues a task and fails to schedule the L81: * worker, and then the first thread's call to delegate.execute() returns. Without this counter, L82: * it would observe the QUEUING state and set it to QUEUED, and the worker would never be L83: * scheduled again for future...

L1:/* L2: * Licensed to the Apache Software Foundation (ASF) under one or more L3: * contributor license agreements. See the NOTICE file distributed with L4: * this work for additional information regarding copyright ownership. L5: * The ASF licenses this file to You under the Apache License, Version 2.0 L6: * (the "License"); you may not use this file except in compliance with L7: * the License. You may obtain a copy of the License at L8: * L9: * http://www.apache.org/licenses/LICENSE-2.0...