- Sort Score
- Result 10 results
- Languages All
Results 31 - 40 of about 10,000 for finalA (0.11 sec)
-
subprojects/core/src/main/java/org/gradle/internal/work/DefaultAsyncWorkTracker.java
public class DefaultAsyncWorkTracker implements AsyncWorkTracker { private final ListMultimap<BuildOperationRef, AsyncWorkCompletion> items = ArrayListMultimap.create(); private final Set<BuildOperationRef> waiting = new HashSet<>(); private final ReentrantLock lock = new ReentrantLock(); private final WorkerLeaseService workerLeaseService;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Dec 11 13:37:56 UTC 2023 - 6K bytes - Viewed (0) -
src/main/java/org/codelibs/core/crypto/CachedCipher.java
offerEncryptoCipher(cipher); } return encrypted; } public byte[] encrypto(final byte[] data, final Key key) { final Cipher cipher = pollEncryptoCipher(key); byte[] encrypted; try { encrypted = cipher.doFinal(data); } catch (final IllegalBlockSizeException e) { throw new IllegalBlockSizeRuntimeException(e);
Registered: Wed Jun 12 12:50:12 UTC 2024 - Last Modified: Thu Mar 07 01:59:08 UTC 2024 - 8.1K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/process/internal/DefaultExecHandle.java
*/ private final List<String> arguments; /** * The variables to set in the environment the executable is run in. */ private final Map<String, String> environment; private final StreamsHandler outputHandler; private final StreamsHandler inputHandler; private final boolean redirectErrorStream; private final ProcessLauncher processLauncher;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Jan 26 14:58:23 UTC 2024 - 15.2K bytes - Viewed (0) -
platforms/software/testing-base/src/main/java/org/gradle/api/internal/tasks/testing/worker/ForkingTestClassProcessor.java
private final WorkerProcessFactory workerFactory; private final WorkerTestClassProcessorFactory processorFactory; private final JavaForkOptions options; private final ForkedTestClasspath classpath; private final Action<WorkerProcessBuilder> buildConfigAction; private final Lock lock = new ReentrantLock(); private final WorkerThreadRegistry workerThreadRegistry;
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Mar 12 12:13:32 UTC 2024 - 7.6K bytes - Viewed (0) -
android/guava-tests/benchmark/com/google/common/util/concurrent/MonitorBasedArrayBlockingQueue.java
* found in any textbook. */ /** Monitor guarding all access */ final Monitor monitor; /** Guard for waiting takes */ private final Monitor.Guard notEmpty; /** Guard for waiting puts */ private final Monitor.Guard notFull; // Internal helper methods /** Circularly increment i. */ final int inc(int i) { return (++i == items.length) ? 0 : i; } /**
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Apr 19 19:24:36 UTC 2023 - 22.5K bytes - Viewed (0) -
src/main/java/org/codelibs/core/io/CopyUtil.java
assertArgumentNotNull("in", in); assertArgumentNotEmpty("encoding", encoding); assertArgumentNotNull("out", out); final Reader is = ReaderUtil.create(in, encoding); try { final Writer os = WriterUtil.create(out); try { return copyInternal(wrap(is), wrap(os)); } finally {
Registered: Wed Jun 12 12:50:12 UTC 2024 - Last Modified: Thu Mar 07 01:59:08 UTC 2024 - 52.4K bytes - Viewed (0) -
testing/internal-testing/src/main/groovy/org/gradle/test/fixtures/concurrent/TestExecutor.groovy
import java.util.concurrent.locks.Lock import java.util.concurrent.locks.ReentrantLock class TestExecutor implements Executor { private final Lock lock = new ReentrantLock() private final Condition condition = lock.newCondition() private final Set<Thread> threads = new HashSet<Thread>() private final TestLogger logger private Thread owner private Throwable failure private int threadNum
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 3.9K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/AbstractService.java
} }; private static final ListenerCallQueue.Event<Listener> STOPPING_FROM_STARTING_EVENT = stoppingEvent(STARTING); private static final ListenerCallQueue.Event<Listener> STOPPING_FROM_RUNNING_EVENT = stoppingEvent(RUNNING); private static final ListenerCallQueue.Event<Listener> TERMINATED_FROM_NEW_EVENT = terminatedEvent(NEW);
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri May 12 18:32:03 UTC 2023 - 20.7K bytes - Viewed (0) -
subprojects/core/src/main/java/org/gradle/deployment/internal/DefaultContinuousExecutionGate.java
import java.util.concurrent.locks.ReentrantLock; public class DefaultContinuousExecutionGate implements ContinuousExecutionGate { private final Lock lock = new ReentrantLock(); private final Condition opened = lock.newCondition(); private final List<GateKeeper> gatekeepers = new ArrayList<>(); private GateKeeper openedBy; @Override public GateKeeper createGateKeeper() { lock.lock();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Dec 11 13:37:56 UTC 2023 - 3.2K bytes - Viewed (0) -
platforms/core-execution/persistent-cache/src/main/java/org/gradle/cache/internal/locklistener/DefaultFileLockContentionHandler.java
private static final Logger LOGGER = LoggerFactory.getLogger(DefaultFileLockContentionHandler.class); private static final int PING_DELAY = 1000; private final Lock lock = new ReentrantLock(); private final Map<Long, ContendedAction> contendedActions = new HashMap<>(); private final Map<Long, FileLockReleasedSignal> lockReleasedSignals = new HashMap<>();
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Apr 16 15:49:51 UTC 2024 - 12.4K bytes - Viewed (0)