Search Options

Results per page
Sort
Preferred Languages
Advance

Results 141 - 150 of 288 for synchronized (0.08 sec)

  1. fess-crawler/src/main/java/org/codelibs/fess/crawler/service/impl/DataServiceImpl.java

         */
        @Override
        public void store(final AccessResultImpl<Long> accessResult) {
            if (accessResult == null) {
                throw new CrawlerSystemException("AccessResult is null.");
            }
    
            synchronized (idCountLock) {
                idCount++;
                accessResult.setId(idCount);
                AccessResultData<Long> accessResultData = accessResult.getAccessResultData();
                if (accessResultData == null) {
    Registered: Sun Nov 10 03:50:12 UTC 2024
    - Last Modified: Thu Feb 22 01:47:32 UTC 2024
    - 5.5K bytes
    - Viewed (0)
  2. mockwebserver/src/main/kotlin/mockwebserver3/MockWebServer.kt

      var bodyLimit: Long = Long.MAX_VALUE
    
      var serverSocketFactory: ServerSocketFactory? = null
        @Synchronized get() {
          if (field == null && started) {
            field = ServerSocketFactory.getDefault() // Build the default value lazily.
          }
          return field
        }
    
        @Synchronized set(value) {
          check(!started) { "serverSocketFactory must not be set after start()" }
          field = value
        }
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sun Mar 31 17:16:15 UTC 2024
    - 37.4K bytes
    - Viewed (0)
  3. okhttp/src/main/kotlin/okhttp3/internal/connection/RealConnectionPool.kt

        address: Address,
        connectionUser: ConnectionUser,
        routes: List<Route>?,
        requireMultiplexed: Boolean,
      ): RealConnection? {
        for (connection in connections) {
          // In the first synchronized block, acquire the connection if it can satisfy this call.
          val acquired =
            connection.withLock {
              when {
                requireMultiplexed && !connection.isMultiplexed -> false
    Registered: Fri Nov 01 11:42:11 UTC 2024
    - Last Modified: Sat Apr 20 17:03:43 UTC 2024
    - 16.2K bytes
    - Viewed (0)
  4. compat/maven-model-builder/src/main/java/org/apache/maven/model/building/Graph.java

    /**
     * @deprecated use {@link org.apache.maven.api.services.ModelBuilder} instead
     */
    @Deprecated(since = "4.0.0")
    class Graph {
    
        final Map<String, Set<String>> graph = new LinkedHashMap<>();
    
        synchronized void addEdge(String from, String to) throws CycleDetectedException {
            if (graph.computeIfAbsent(from, l -> new HashSet<>()).add(to)) {
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 3.4K bytes
    - Viewed (0)
  5. src/main/java/org/codelibs/fess/es/config/exentity/ElevateWord.java

        public void setLabelTypeIds(final String[] labelTypeIds) {
            this.labelTypeIds = labelTypeIds;
        }
    
        public List<LabelType> getLabelTypeList() {
            if (labelTypeList == null) {
                synchronized (this) {
                    if (labelTypeList == null) {
                        final FessConfig fessConfig = ComponentUtil.getFessConfig();
    Registered: Thu Oct 31 13:40:30 UTC 2024
    - Last Modified: Thu Feb 22 01:37:57 UTC 2024
    - 4.3K bytes
    - Viewed (0)
  6. guava-tests/test/com/google/common/base/FinalizableReferenceQueueTest.java

      }
    
      static class DecoupledClassLoader extends URLClassLoader {
    
        public DecoupledClassLoader(URL[] urls) {
          super(urls);
        }
    
        @Override
        protected synchronized Class<?> loadClass(String name, boolean resolve)
            throws ClassNotFoundException {
          // Force Finalizer to load from this class loader, not its parent.
          if (name.equals(Finalizer.class.getName())) {
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 14:28:19 UTC 2024
    - 4.8K bytes
    - Viewed (0)
  7. compat/maven-resolver-provider/src/main/java/org/apache/maven/repository/internal/DefaultModelCache.java

            }
    
            @Override
            @SuppressWarnings({"unchecked", "checkstyle:InnerAssignment"})
            public T get() {
                Object v;
                if ((v = value) == null) {
                    synchronized (this) {
                        if ((v = value) == null) {
                            try {
                                v = value = supplier.get();
                            } catch (Exception e) {
    Registered: Sun Nov 03 03:35:11 UTC 2024
    - Last Modified: Fri Oct 25 12:31:46 UTC 2024
    - 6.6K bytes
    - Viewed (0)
  8. 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 Nov 06 11:36:14 UTC 2024
    - Last Modified: Fri Jun 28 08:29:28 UTC 2024
    - 4.2K bytes
    - Viewed (0)
  9. src/main/java/org/codelibs/core/sql/DriverManagerUtil.java

            } catch (final SQLException e) {
                throw new SQLRuntimeException(e);
            }
        }
    
        /**
         * 現在のクラスローダに結びつけられている全てのJDBCドライバを登録解除します。
         */
        public static synchronized void deregisterAllDrivers() {
            for (final Enumeration<Driver> e = DriverManager.getDrivers(); e.hasMoreElements();) {
                deregisterDriver(e.nextElement());
            }
        }
    
    Registered: Fri Nov 01 20:58:10 UTC 2024
    - Last Modified: Thu Mar 07 01:59:08 UTC 2024
    - 3.3K bytes
    - Viewed (0)
  10. guava-tests/test/com/google/common/cache/CacheReferencesTest.java

      static class Key {
        private final int value;
        private WeakReference<String> toString;
    
        Key(int value) {
          this.value = value;
        }
    
        @Override
        public synchronized String toString() {
          String s;
          if (toString != null) {
            s = toString.get();
            if (s != null) {
              return s;
            }
          }
          s = Integer.toString(value);
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Mon Oct 21 14:28:19 UTC 2024
    - 6.2K bytes
    - Viewed (0)
Back to top