使用Barrier来控制线程同步示例

可能的输出：


代码如下:

Working on Thread A
Working on Thread B
Thread B will sleep for 10 seconds.
Thread A will sleep for 847 seconds.
Working on Thread C
Thread C will sleep for 26 seconds.
Working on Thread D
Thread D will sleep for 351 seconds.
Working on Thread E
Thread E will sleep for 249 seconds.

All jobs have been done.

代码：


代码如下:

using System;
using System.Threading;

class BarrierDemo
{
    static Barrier _barrier = new Barrier (5, barrier => {
            Console.WriteLine();
            Console.WriteLine("All jobs have been done.");
        });

static void Main()
    {
        Random r = new Random();

new Thread(Work).Start(new MyThreadArgs { ThreadId = "A",
            WaitTimeCount = r.Next(1000) });
        new Thread(Work).Start(new MyThreadArgs {ThreadId = "B",
            WaitTimeCount = r.Next(1000) });
        new Thread(Work).Start(new MyThreadArgs {ThreadId = "C",
            WaitTimeCount = r.Next(1000) });
        new Thread(Work).Start(new MyThreadArgs {ThreadId = "D",
            WaitTimeCount = r.Next(1000) });
        new Thread(Work).Start(new MyThreadArgs {ThreadId = "E",
            WaitTimeCount = r.Next(1000) });
    }

static void Work(object obj)
    {
        MyThreadArgs args = (MyThreadArgs) obj;

Console.WriteLine("Working on Thread " + args.ThreadId);
        Console.WriteLine("Thread " + args.ThreadId +
            " will sleep for " + args.WaitTimeCount + " seconds.");

Thread.Sleep(waitTime);

_barrier.SignalAndWait();
    }

class MyThreadArgs
    {
        public string ThreadId { get; set; }
        public int WaitTimeCount { get; set; }
    }
}

赞 (0)

相关推荐

  • 使用Barrier来控制线程同步示例

    可能的输出: 复制代码 代码如下: Working on Thread AWorking on Thread BThread B will sleep for 10 seconds.Thread A will sleep for 847 seconds.Working on Thread CThread C will sleep for 26 seconds.Working on Thread DThread D will sleep for 351 seconds.Working on Thr

  • 浅析c# 线程同步

    同步是一种只允许一个线程在特定时间访问某些资源的技术.没有其他线程可以中断,直到所分配的线程或当前访问线程访问数据完成其任务. 在多线程程序中,允许线程访问任何资源所需的执行时间.线程共享资源并异步执行. 访问共享资源(数据)是有时可能会暂停系统的关键任务.所以可以通过线程同步来处理它. 主要场景如:存款,取款等交易业务处理. 线程同步的优点 一致性维护 无线程干扰 C#锁定 使用 C# lock关键字同步执行程序.它用于为当前线程锁定,执行任务,然后释放锁定.它确保其他线程在执行完成之前不会中

  • 利用synchronized实现线程同步的案例讲解

    利用synchronized实现线程同步的案例讲解

    一.前期基础知识储备 (1)线程同步的定义:多线程之间的同步. (2)多线程同步原因:一个多线程的程序如果是通过Runnable接口实现的,则意味着类中的属性将被多个线程共享,由此引出资源的同步问题,即当多个线程要操作同一资源时,有可能出现错误. (3)实现多线程同步的方式--引入同步机制:在线程使用一个资源时为其加锁,这样其他的线程便不能访问那个资源了,直到解锁后才可以访问.--这样做的结果,所有线程间会有资源竞争,但是所有竞争的资源是同步的,刷新的,动态的,不会因为线程间的竞争,导致资源"过

  • c#线程同步使用详解示例

    在应用程序中使用多个线程的一个好处是每个线程都可以异步执行.对于 Windows 应用程序,耗时的任务可以在后台执行,而使应用程序窗口和控件保持响应.对于服务器应用程序,多线程处理提供了用不同线程处理每个传入请求的能力.否则,在完全满足前一个请求之前,将无法处理每个新请求.然而,线程的异步特性意味着必须协调对资源(如文件句柄.网络连接和内存)的访问.否则,两个或更多的线程可能在同一时间访问相同的资源,而每个线程都不知道其他线程的操作. 线程同步的方式 线程同步有:临界区.互斥区.事件.信号量四种

  • java并发编程包JUC线程同步CyclicBarrier语法示例

    java并发编程包JUC线程同步CyclicBarrier语法示例

    目录 1.创建CyclicBarrier障碍 2.在CyclicBarrier障碍处等待 3.CyclicBarrierAction 4.CyclicBarrier例子 在之前的文章中已经为大家介绍了java并发编程的工具:BlockingQueue接口.ArrayBlockingQueue.DelayQueue.LinkedBlockingQueue.PriorityBlockingQueue.SynchronousQueue.BlockingDeque接口.ConcurrentHashMap

  • Java线程创建(卖票)，线程同步(卖包子)的实现示例

    Java线程创建(卖票)，线程同步(卖包子)的实现示例

    1.线程两种创建方式:new Thread(new Runnable() {}) 如下FileOutputStream源码中抛出异常,为了让写代码人自己写try catch异常提示信息. package com.itheim07.thread; /* * 进程和线程 * 1. 进程 : 航空母舰(资源: 燃油 弹药) * 2. 线程 : 舰载机 * 一个软件运行: 一个军事活动, 必须有一艘航母出去,但执行具体任务的是航母上的舰载机 * 一个软件运行,至少一个进程, 一个进程中至少一个线程.谷歌

  • java多线程之线程同步七种方式代码示例

    为何要使用同步?  java允许多线程并发控制,当多个线程同时操作一个可共享的资源变量时(如数据的增删改查),     将会导致数据不准确,相互之间产生冲突,因此加入同步锁以避免在该线程没有完成操作之前,被其他线程的调用,     从而保证了该变量的唯一性和准确性. 1.同步方法  即有synchronized关键字修饰的方法.     由于java的每个对象都有一个内置锁,当用此关键字修饰方法时,     内置锁会保护整个方法.在调用该方法前,需要获得内置锁,否则就处于阻塞状态.     代码

  • Java线程同步Lock同步锁代码示例

    java线程同步原理 java会为每个object对象分配一个monitor,当某个对象的同步方法(synchronizedmethods)被多个线程调用时,该对象的monitor将负责处理这些访问的并发独占要求. 当一个线程调用一个对象的同步方法时,JVM会检查该对象的monitor.如果monitor没有被占用,那么这个线程就得到了monitor的占有权,可以继续执行该对象的同步方法:如果monitor被其他线程所占用,那么该线程将被挂起,直到monitor被释放. 当线程退出同步方法调用时

  • python自定义线程池控制线程数量的示例

    1.自定义线程池 import threading import Queue import time queue = Queue.Queue() def put_data_in_queue(): for i in xrange(10): queue.put(i) class MyThread(threading.Thread): def run(self): while not queue.empty(): sleep_times = queue.get() time.sleep(sleep_t

  • C++同步线程实现示例详解

    目录 一.同步线程 二.独占访问示例 一.同步线程 虽然使用多线程可以提高应用程序的性能,但通常也会增加复杂性.如果同时执行多个函数,则必须同步对共享资源的访问.一旦应用程序达到一定大小,这将涉及大量的编程工作.本节介绍Boost.Thread提供的用于同步线程的类. 二.独占访问示例 示例 44.7.使用 boost::mutex 的独占访问 #include <boost/thread.hpp> #include <boost/chrono.hpp> #include <

随机推荐