- Sort Score
- Result 10 results
- Languages All
Results 331 - 340 of 507 for nolock (0.11 sec)
-
src/main/webapp/WEB-INF/view/searchResults.jsp
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Jun 09 04:29:42 UTC 2022 - 9K bytes - Viewed (0) -
docs/pt/docs/python-types.md
//// tab | Python 3.9+ Declare uma variável com a mesma sintaxe com dois pontos (`:`) Como tipo, coloque `list`. Como a lista é o tipo que contém algum tipo interno, você coloca o tipo dentro de colchetes: ```Python hl_lines="1" {!> ../../docs_src/python_types/tutorial006_py39.py!} ``` //// //// tab | Python 3.8+ De `typing`, importe `List` (com o `L` maiúsculo):
Registered: Sun Nov 03 07:19:11 UTC 2024 - Last Modified: Tue Oct 15 12:32:27 UTC 2024 - 18K bytes - Viewed (0) -
cmd/peer-rest-client.go
} st, err := gridConn.NewStream(ctx, grid.HandlerTrace, payload) if err != nil { return } st.Results(func(b []byte) error { select { case traceCh <- b: default: // Do not block on slow receivers. // Just recycle the buffer. grid.PutByteBuffer(b) } return nil }) } func (client *peerRESTClient) doListen(ctx context.Context, listenCh chan<- []byte, v url.Values) {
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Mon Sep 09 16:58:30 UTC 2024 - 26.1K bytes - Viewed (0) -
src/main/webapp/js/suggestor.js
Registered: Thu Oct 31 13:40:30 UTC 2024 - Last Modified: Thu Mar 30 05:45:24 UTC 2023 - 13.3K bytes - Viewed (0) -
docs/bigdata/README.md
``` cat ${HADOOP_CONF_DIR}/core-site.xml | kv-pairify | grep "s3a" fs.s3a.access.key=minio fs.s3a.secret.key=minio123 fs.s3a.path.style.access=true fs.s3a.block.size=512M fs.s3a.buffer.dir=${hadoop.tmp.dir}/s3a fs.s3a.committer.magic.enabled=false fs.s3a.committer.name=directory fs.s3a.committer.staging.abort.pending.uploads=true fs.s3a.committer.staging.conflict-mode=append
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Sep 29 04:28:45 UTC 2022 - 14.7K bytes - Viewed (0) -
guava/src/com/google/common/util/concurrent/ExecutionSequencer.java
import javax.annotation.CheckForNull; import org.checkerframework.checker.nullness.qual.Nullable; /** * Serializes execution of tasks, somewhat like an "asynchronous {@code synchronized} block." Each * {@linkplain #submit enqueued} callable will not be submitted to its associated executor until the * previous callable has returned -- and, if the previous callable was an {@link AsyncCallable}, not
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Thu Feb 01 21:46:34 UTC 2024 - 22.1K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ExecutionList.java
// is likely to be a bug anyway. // N.B. All writes to the list and the next pointers must have happened before the above // synchronized block, so we can iterate the list without the lock held here. RunnableExecutorPair reversedList = null; while (list != null) { RunnableExecutorPair tmp = list; list = list.next; tmp.next = reversedList;
Registered: Fri Nov 01 12:43:10 UTC 2024 - Last Modified: Mon Apr 22 21:17:24 UTC 2024 - 6.9K bytes - Viewed (0) -
src/main/java/jcifs/smb1/smb1/SmbNamedPipe.java
* Pipe instance although this is not a requirement (e.g. a * read-only named pipe would write data to this stream on * connection). Reading from this stream may block. Therefore it * may be necessary that an addition thread be used to read and * write to a Named Pipe. */ public InputStream getNamedPipeInputStream() throws IOException {
Registered: Sun Nov 03 00:10:13 UTC 2024 - Last Modified: Fri Mar 22 21:10:40 UTC 2019 - 7.3K bytes - Viewed (0) -
internal/event/target/amqp.go
return true } if nerr, ok := err.(*net.OpError); ok { return (nerr.Err.Error() == "use of closed network connection") } return false } target.connMutex.Lock() defer target.connMutex.Unlock() if target.conn != nil { ch, err = target.conn.Channel() if err == nil { if target.args.PublisherConfirms { confirms := ch.NotifyPublish(make(chan amqp091.Confirmation, 1))
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Sep 06 23:06:30 UTC 2024 - 10K bytes - Viewed (0) -
cmd/prepare-storage.go
return func(endpoint Endpoint, err error, once bool) { reqInfo := (&logger.ReqInfo{}).AppendTags("endpoint", endpoint.String()) ctx := logger.SetReqInfo(GlobalContext, reqInfo) mutex.Lock() defer mutex.Unlock() m, ok := printOnce[endpoint] if !ok { m = make(map[string]int) printOnce[endpoint] = m if once { m[err.Error()]++ peersLogAlwaysIf(ctx, err) return } }
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Fri Jul 12 20:51:54 UTC 2024 - 11.1K bytes - Viewed (0)