雖然另一個答案是一種可能的方法，但我的答案主要是從另一個角度來回答，試圖看看你的代碼可能有什么問題。。。 如果你不想在flag設置為false時等待一秒鐘，并且你想要至少1000毫秒的延遲，那么Sleep的循環可以工作，但是你需要 原子變量（例如std::atomic） 或函數（例如InterlockedCompareExchange） 或MemoryBarrier 或其他同步方式來檢查標志。 如果沒有適當的同步，就不能保證編譯器將從內存而不是緩存或寄存器讀取值。 從UIthread使用Sleep或類似函數也會引起懷疑。 對于控制臺應用程序，如果應用程序的目的確實是在給定的持續時間內工作，則可以在主thread中等待一段時間。但通常，您可能希望等待處理完成。在大多數情況下，您通常應該等待您開始的threads完成。 Sleep函數的另一個問題是thread總是必須每隔幾秒鐘醒來，即使沒有什么事情可做。如果您想優化電池使用，這可能會很糟糕。然而，另一方面，如果您的代碼中有一些bug，那么在等待某個信號（句柄）的函數上有一個相對較長的超時可能會使您的代碼對錯過的喚醒更加健壯。 在某些情況下，您還需要延遲，因為您實際上沒有任何東西需要等待，但需要定期提取一些數據。 一個大的超時也可以作為一種看門狗定時器。例如，如果您希望有一些事情要做，但在很長一段時間內什么也沒有收到，您可以報告一個警告

如何使其同時運行？ 您可以： 生成一個任務，它將使每個hello_wait獨立地被調度 或者“合并”期貨，這將同時推動所有期貨并行運行 您的期望可能來自Javascript或C#async，其中等待的“基礎”是一項任務。任務是“活動的”，一旦您創建它們，它們就可以被安排并同時執行任務。 但是rust的核心更像是一個協同程序，所以它是惰性的（/被動的）：創建一個程序并沒有真正做任何事情，必須對未來進行輪詢，并且await將重復輪詢直到完成，然后再恢復。所以當你await某個程序時，它完全沒有機會在那一點進行交錯。 因此，同時運行期貨需要兩件事之一： 將它們升級到任務，意味著它們可以自己安排，這就是spawn所做的 或者將期貨組合成一個"meta-future，當它被輪詢時，它可以依次輪詢所有期貨，這就是像join_all或tokio::join這樣的構造所做的 請注意，編寫未來不允許并行性，因為未來是“兄弟”，它們只能連續地進行輪詢（從而實際執行操作），只是這種輪詢（從而進行）是交錯的。 產卵任務確實允許并行性（如果運行時是多線程的，并且機器有多個內核——盡管后者現在非常普遍），但在生命周期和內存管理方面有其自身的局限性，而且成本更高。 這里是一個各種選項的游樂場演示。它使用tokio，因為顯然操場上沒有async_std，而且我不確定是否有可能啟用“不穩定”功能，但除此之外，使用

你絕不能讓消費者睡覺thread，以避免重新平衡。 相反，減少max.poll.records，這樣暫停會更快生效（消費者在前一次民意調查收到的記錄得到處理之前不會真正暫停）。 您可以在暫停使用者后引發異常，但您需要以某種方式恢復容器。 我打開了一個新問題來改進這種行為https://github.com/spring-projects/spring-kafka/issues/2280 如果您受到速率限制，請考慮在時間表上使用KafkaTemplate.receive()方法或輪詢的Spring Integration適配器，而不是使用message-driven方法。

在這種情況下，您不需要取消超時，只要在它觸發時忽略它即可 具有全局（當然可以是命名空間）變量，啟動時將其設置為true/false，停止時將其設置為false/true。 使用true（活動）/false（停止）更新代碼段。 您還可以使用相反的var cancelled = false;，然后在單擊并檢查false時將其設置為true。 var active;function sleep(ms) { return new Promise(resolve => setTimeout(resolve, ms));}$('#target').click(function(e) { e.preventDefault(); // try to stop the countdown active = false;});async function start() { active = true; for (index = 0; index < 5; index++) { await sleep(1000); if (!active) break; $('#timer').text(index); }}start(); <script src="https://cdnjs.cloudflare.com/ajax/libs/jquery/3.3.1/jquery.min.js"&

time() - initTime是讀取循環每次重復的時間。 對于循環的單個重復，讀取+1-（time（）-initTime）睡眠需要花費time（）-nittime。 總共：1-（time（）-initTime）+（time（）-nittime）=1秒。 因此，當使用sleep(1 - (time() - initTime))時，每個循環重復時間非常接近1秒。 為什么不使用sleep(1)？-Because它沒有那么精確。每次循環迭代將持續1秒以上：（time（）-initTime）讀取時間+1秒睡眠時間。

主thread/queue是接口thread/queue，因此time-consuming活動凍結了接口。 可能是multithreading編程 的確。實際問題的答案是：在后臺thread/隊列上執行time-consuming活動。 DispatchQueue.global(qos: .background).async { // your code here} 當然，這引起了concurrency-related問題的幽靈，這些問題涉及同一代碼的多次同時執行、對共享數據的訪問之間的non-thread-safe沖突等等。但這是做time-consuming事情的代價，你只需學會應付。

（至少）四個問題： 首先，你并沒有真正讓t2睡覺。Thread.sleep是一個靜態方法，因此t2.sleep(1_000)實際上是Thread.sleep(1_000)，所以您只是讓當前的thread休眠。 （你能想象如果你被允許讓別人睡threads睡眠arbitrarily...?）你會造成什么樣的傷害嗎 其次，您實際上并沒有檢查Test2中的中斷。所以，當你打斷它的時候，沒有人在聽你的打擾，所以什么也不會發生。 如果你想檢查是否有干擾，你可以做一些類似的事情 while (!interrupted()) {} 但即使這樣也不會拋出InterruptedException：循環將停止執行。 第三，Test2在其run()方法中拋出了InterruptedException，它必須在該方法中處理。InterruptedException是一個檢查異常，因此您不能將throws InterruptedException添加到其簽名中，因為run()沒有聲明它拋出任何已檢查的異常。因此，它永遠不會“逃脫”這種方法。 第四，即使您確實設法讓InterruptedException逃離Thread.run()方法（有很多陰險邪惡的方法可以做到這一點），但這并不意味著它可以在主thread中被捕獲。異常將由未捕獲的異常處理程序處理，主thread將繼續none-the-wiser。

您可以使用time模塊： from time import timestart_time = time()end_time = start_time + 3next_z = start_time + 0.5while next_z < end_time: if time() > next_z: print('z') next_z += 0.5

只需添加事件偵聽器，在調用后將其刪除，然后設置超時以再次添加。 function scrollHandler() { window.removeEventListener('scroll', scrollHandler); // Detects new state and compares it with the old one if ((document.body.getBoundingClientRect()).top > iniState) console.log('up'); else console.log('down'); // Saves the new position for iteration. iniState = (document.body.getBoundingClientRect()).top; setTimeout(() => window.addEventListener('scroll', scrollHandler), 2000);}window.addEventListener('scroll', scrollHandler);

報錯是因為沒有關閉foo6Chan這個channel，會一直阻塞在for循環。解決：...foo6Chan <- 5close(foo6Chan) // 關閉channlefoo6()添加go關鍵字不報錯是因為在另一個線程中阻塞了，2秒后主函數結束會殺掉線程。

拋開顯示的代碼試圖創建10000threads，如果創建成功，將打印10000行而不是3000行，核心問題是： 為什么threadsprint與不等待相比，如果每個thread等待1s，那么threadsprint會更少？ Possible reasoning: 每個thread消耗資源。因此，并發存在的thread的最大數目是有限的。 如果每個thread在結束前等待1s，那么可以假設可用資源被消耗的速度比thread立即存在時要快。因此，如果資源耗盡，thread創建就會失敗，代碼會忽略這一點，但只會嘗試創建下一個。 要查看代碼的實際情況，應該記錄創建失敗的情況，如下所示： #include <stdio.h> #include <unistd.h>#include <pthread.h> #include <errno.h>void *thread_func(void) { sleep(1); /* Removing this probably lowers the number of failed creations. */ printf("\n"); return NULL;} int main(void) { int i; for (i = 0; i < 10000; i++) { pthread_t tid; if

你可能需要實現一個“特殊的可中斷睡眠”……像這樣的東西可能是一個“有效”的幼稚實現 def do_something(): pass class Program: flag = True def stoppable_sleep(self,t): endTime = time.time() + t while time.time() < endTime and self.flag: time.sleep(0.1) def mainloop(self): while flag: do_something() self.stoppable_sleep(60) print("Done...") def stop(self): self.flag = Falsep = Program()threading.Timer(5,p.stop)p.mainloop()

clock是否度量sleep，即掛起threads？ No. ）好吧，它可以測量，沒有什么不對勁的。可能有一個非常糟糕的操作系統將sleep()實現為while (!time_to_sleep_expired()) {}繁忙循環。但是任何self-respected操作系統都會嘗試使進程在sleep()中不使用CPU。 這意味著時鐘不會測量進程的cpu-time（滴答聲），因為它不是主動運行的？ Yes. 如果是這樣的話，建議用什么方法來測量實際需要的時間？ 要測量"real-time，請在POSIX系統上使用clock_gettime(CLOCK_MONOTONIC, ...)。 每秒的時鐘滴答數可以使用：sysconf(_SC_CLK_TCK)； 是的，但是請注意sysconf(_SC_CLK_TCK);不是CLOCKS_PER_SECOND。你不使用extimes()在你的函數中，你使用clock()，我真的不明白你為什么打印sysconf(_SC_CLK_TCK);。無論如何，請參見示例sysconf(_SC_CLK_TCK)與CLOCKS_PER_SEC。

看code，應該是用waitgroup來做收尾工作，兩個goroutine交替執行。問題出在B routine的最后一次寫入A <- true，這個時候從A channel讀入數據的code已經沒有機會執行了，所以程序hang在那里了加一個簡單的讀入，就可以順利執行了func main() { A := make(chan bool) B := make(chan bool) defer close(A) defer close(B) var wg sync.WaitGroup wg.Add(2) go func() { for i := 0; i < 10; i += 2 { if <-A { fmt.Println(i) B <- true } } <-A wg.Done() }() go func() { for i := 1; i < 10; i += 2 { if <-B { fmt.Println(i) A <- true } } wg.Done() }() A <- true wg.Wait()}已參與了 SegmentFault 思否社區 10 周年「問答」打卡 ，歡迎正在閱讀的你也加入。

幸運的是，您已經處于async上下文中。setTimeout很容易承諾： function delay(time) { return new Promise(resolve => setTimeout(resolve, time));} 然后簡單地插入await delay(1000)等待一秒鐘。