- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 29 for synchronized (0.22 sec)
-
src/main/java/org/codelibs/fess/dict/kuromoji/KuromojiFile.java
} @Override public synchronized void insert(final KuromojiItem item) { try (KuromojiUpdater updater = new KuromojiUpdater(item)) { reload(updater); } } @Override public synchronized void update(final KuromojiItem item) { try (KuromojiUpdater updater = new KuromojiUpdater(item)) {
Registered: Mon Oct 28 08:04:08 UTC 2024 - Last Modified: Fri Oct 11 21:11:58 UTC 2024 - 9.7K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/dict/synonym/SynonymFile.java
} @Override public synchronized void insert(final SynonymItem item) { try (SynonymUpdater updater = new SynonymUpdater(item)) { reload(updater); } } @Override public synchronized void update(final SynonymItem item) { try (SynonymUpdater updater = new SynonymUpdater(item)) {
Registered: Mon Oct 28 08:04:08 UTC 2024 - Last Modified: Fri Oct 11 21:11:58 UTC 2024 - 12.5K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/dict/mapping/CharMappingFile.java
} @Override public synchronized void insert(final CharMappingItem item) { try (MappingUpdater updater = new MappingUpdater(item)) { reload(updater); } } @Override public synchronized void update(final CharMappingItem item) { try (MappingUpdater updater = new MappingUpdater(item)) {
Registered: Mon Oct 28 08:04:08 UTC 2024 - Last Modified: Fri Oct 11 21:11:58 UTC 2024 - 10.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/dict/protwords/ProtwordsFile.java
} @Override public synchronized void insert(final ProtwordsItem item) { try (ProtwordsUpdater updater = new ProtwordsUpdater(item)) { reload(updater); } } @Override public synchronized void update(final ProtwordsItem item) { try (ProtwordsUpdater updater = new ProtwordsUpdater(item)) {
Registered: Mon Oct 28 08:04:08 UTC 2024 - Last Modified: Fri Oct 11 21:11:58 UTC 2024 - 9.6K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/dict/stopwords/StopwordsFile.java
} @Override public synchronized void insert(final StopwordsItem item) { try (SynonymUpdater updater = new SynonymUpdater(item)) { reload(updater); } } @Override public synchronized void update(final StopwordsItem item) { try (SynonymUpdater updater = new SynonymUpdater(item)) {
Registered: Mon Oct 28 08:04:08 UTC 2024 - Last Modified: Fri Oct 11 21:11:58 UTC 2024 - 9.6K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/dict/stemmeroverride/StemmerOverrideFile.java
} @Override public synchronized void insert(final StemmerOverrideItem item) { try (StemmerOverrideUpdater updater = new StemmerOverrideUpdater(item)) { reload(updater); } } @Override public synchronized void update(final StemmerOverrideItem item) {
Registered: Mon Oct 28 08:04:08 UTC 2024 - Last Modified: Fri Oct 11 21:11:58 UTC 2024 - 10.6K bytes - Viewed (0) -
internal/logger/logrotate.go
type Writer struct { // opts are the configuration options for this Writer opts Options // f is the currently open file used for appends. // Writes to f are only synchronized once Close() is called, // or when files are being rotated. f *os.File pw *xioutil.PipeWriter pr *xioutil.PipeReader } // Write writes p into the current file, rotating if necessary.
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 5.8K bytes - Viewed (0) -
internal/cachevalue/cache.go
// If NoWait is set, Get() will return the last good value, // if TTL has expired but 2x TTL has not yet passed, // but will fetch a new value in the background. NoWait bool } // Cache contains a synchronized value that is considered valid // for a specific amount of time. // An Update function must be set to provide an updated value when needed. type Cache[T any] struct { // updateFn must return an updated value.
Registered: Sun Oct 27 19:28:09 UTC 2024 - Last Modified: Fri May 24 12:50:46 UTC 2024 - 4.4K bytes - Viewed (0) -
build-logic/cleanup/src/main/kotlin/gradlebuild/cleanup/services/CachesCleaner.kt
abstract val fileSystemOperations: FileSystemOperations private var hasCleaned = false val logger = Logging.getLogger(CachesCleaner::class.java) fun cleanUpCaches() { synchronized(this) { if (hasCleaned) { return } logger.lifecycle("Cleaning up caches...") val homeDir = parameters.homeDir.get()
Registered: Wed Oct 30 11:36:09 UTC 2024 - Last Modified: Fri Jun 28 08:29:28 UTC 2024 - 4.2K bytes - Viewed (0) -
src/main/java/org/codelibs/fess/helper/ProcessHelper.java
return startProcess(sessionId, cmdList, pbCall, InputStreamThread.MAX_BUFFER_SIZE, null); } public synchronized JobProcess startProcess(final String sessionId, final List<String> cmdList, final Consumer<ProcessBuilder> pbCall, final int bufferSize, final Consumer<String> outputCallback) {
Registered: Mon Oct 28 08:04:08 UTC 2024 - Last Modified: Fri Oct 11 21:20:39 UTC 2024 - 6.4K bytes - Viewed (0)